public class TPCHQuery3Table$ extends Object
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
Modifier and Type | Field and Description |
---|---|
static TPCHQuery3Table$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TPCHQuery3Table$() |
public static final TPCHQuery3Table$ MODULE$
public void main(String[] args)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.