org.apache.flink.examples.java.relational

Class TPCHQuery3

java.lang.Object

org.apache.flink.examples.java.relational.TPCHQuery3

public class TPCHQuery3
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 (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/.

Usage: TPCHQuery3 --lineitem<path> --customer <path> --orders<path> --output <path>

This example shows how to use:

• custom data type derived from tuple data types
• inline-defined functions
• build-in aggregation functions

Note: All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API. This class is retained for testing purposes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TPCHQuery3.Customer Customer.
static class	TPCHQuery3.Lineitem Lineitem.
static class	TPCHQuery3.Order Order.
static class	TPCHQuery3.ShippingPriorityItem ShippingPriorityItem.

Constructor Summary

Constructors

Constructor and Description
TPCHQuery3()

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

TPCHQuery3

public TPCHQuery3()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception