org.apache.flink.examples.scala

Class TPCHQuery3Table

java.lang.Object

org.apache.flink.examples.scala.TPCHQuery3Table

public class TPCHQuery3Table
extends Object

This program implements a modified version of the TPC-H query 3. The example demonstrates how to assign names to fields by extending the Tuple class. The original query can be found at [http://www.tpc.org/tpch/spec/tpch2.16.0.pdf](http://www.tpc.org/tpch/spec/tpch2.16.0.pdf) (page 29).

This program implements the following SQL equivalent:

 SELECT 
      l_orderkey, 
      SUM(l_extendedprice*(1-l_discount)) AS revenue,
      o_orderdate, 
      o_shippriority 
 FROM customer, 
      orders, 
      lineitem 
 WHERE
      c_mktsegment = '[SEGMENT]' 
      AND c_custkey = o_custkey
      AND l_orderkey = o_orderkey
      AND o_orderdate < date '[DATE]'
      AND l_shipdate > date '[DATE]'
 GROUP BY
      l_orderkey, 
      o_orderdate, 
      o_shippriority;
 

Compared to the original TPC-H query this version does not sort the result by revenue and orderdate.

Input files are plain text CSV files using the pipe character ('|') as field separator as generated by the TPC-H data generator which is available at [http://www.tpc.org/tpch/](a href="http://www.tpc.org/tpch/).

Usage:

 TPCHQuery3Expression <lineitem-csv path> <customer-csv path> <orders-csv path> <result path>
 

This example shows how to use: - Table API expressions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TPCHQuery3Table.Customer
static class	TPCHQuery3Table.Customer$
static class	TPCHQuery3Table.Lineitem
static class	TPCHQuery3Table.Lineitem$
static class	TPCHQuery3Table.Order
static class	TPCHQuery3Table.Order$

Constructor Summary

Constructors

Constructor and Description
TPCHQuery3Table()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TPCHQuery3Table

public TPCHQuery3Table()

Method Detail

main

public static void main(String[] args)