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
ORDER BY
revenue desc,
o_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: - Convert DataSets to Tables - Use Table API expressions
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 and Description |
---|
TPCHQuery3Table() |
public static void main(String[] args)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.