org.apache.flink.examples.java.relational

Class TPCHQuery10

java.lang.Object

org.apache.flink.examples.java.relational.TPCHQuery10

public class TPCHQuery10
extends Object

This program implements a modified version of the TPC-H query 10. The original query can be found at http://www.tpc.org/tpch/spec/tpch2.16.0.pdf (page 45).

This program implements the following SQL equivalent:

 SELECT
        c_custkey,
        c_name,
        c_address,
        n_name,
        c_acctbal
        SUM(l_extendedprice * (1 - l_discount)) AS revenue,
 FROM
        customer,
        orders,
        lineitem,
        nation
 WHERE
        c_custkey = o_custkey
        AND l_orderkey = o_orderkey
        AND YEAR(o_orderdate) > '1990'
        AND l_returnflag = 'R'
        AND c_nationkey = n_nationkey
 GROUP BY
        c_custkey,
        c_name,
        c_acctbal,
        n_name,
        c_address
 

Compared to the original TPC-H query this version does not print c_phone and c_comment, only filters by years greater than 1990 instead of a period of 3 months, and does not sort the result by revenue.

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: TPCHQuery10 --customer <path> --orders <path> --lineitem<path> --nation <path> --output <path>

This example shows how to use:

• tuple data types
• inline-defined functions
• projection and join projection
• built-in aggregation functions

Constructor Summary

Constructors

Constructor and Description
TPCHQuery10()

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

TPCHQuery10

public TPCHQuery10()

Method Detail

main

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

Throws:

Exception