blob: f957889b6888337763dabad116e18841e6d3428b [file] [log] [blame]
Yingyi Bu8f6301f2016-03-05 01:10:05 -08001/*
2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements. See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License. You may obtain a copy of the License at
9 *
10 * http://www.apache.org/licenses/LICENSE-2.0
11 *
12 * Unless required by applicable law or agreed to in writing,
13 * software distributed under the License is distributed on an
14 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15 * KIND, either express or implied. See the License for the
16 * specific language governing permissions and limitations
17 * under the License.
18 */
19
20drop dataverse tpch if exists;
21create dataverse tpch;
22use dataverse tpch;
23
24create type LineItemType as
25{ l_orderkey: int64, l_partkey: int64, l_suppkey: int64, l_linenumber: int32, l_quantity: int32, l_extendedprice: double, l_discount: double, l_tax: double, l_returnflag: string, l_linestatus: string, l_shipdate: string, l_commitdate: string, l_receiptdate: string, l_shipinstruct: string, l_shipmode: string, l_comment: string }
26
27create type OrderType as
28{ o_orderkey: int64, o_custkey: int64, o_orderstatus: string, o_totalprice: double, o_orderdate: string, o_orderpriority: string, o_clerk: string, o_shippriority: int32, o_comment: string }
29
30create type CustomerType as
31{ c_custkey: int64, c_name: string, c_address: string, c_nationkey: int32, c_phone: string, c_acctbal: double, c_mktsegment: string, c_comment: string }
32
33create type PartType as
34{ p_partkey: int64, p_name: string, p_mfgr: string, p_brand: string, p_type: string, p_size: int32, p_container: string, p_retailprice: double, p_comment: string }
35
36create type PartSuppType as
37{ ps_partkey: int64, ps_suppkey: int64, ps_availqty: int32, ps_supplycost: double, ps_comment: string }
38
39create type SupplierType as
40{ s_suppkey: int64, s_name: string, s_address: string, s_nationkey: int32, s_phone: string, s_acctbal: double, s_comment: string }
41
42create type NationType as
43{ n_nationkey: int32, n_name: string, n_regionkey: int32, n_comment: string }
44
45create type RegionType as
46{ r_regionkey: int32, r_name: string, r_comment: string }
47
48create dataset LineItem(LineItemType) primary key l_orderkey, l_linenumber;
49create dataset Orders(OrderType) primary key o_orderkey;
50create dataset Customer(CustomerType) primary key c_custkey;
51create dataset Part(PartType) primary key p_partkey;
52create dataset Partsupp(PartSuppType) primary key ps_partkey, ps_suppkey;
53create dataset Supplier(SupplierType) primary key s_suppkey;
54create dataset Region(RegionType) primary key r_regionkey;
55create dataset Nation(NationType) primary key n_nationkey;
56
57
58create index nation_fk_region on Nation(n_regionkey);
59create index supplier_fk_nation on Supplier (s_nationkey);
60create index partsupp_fk_part on Partsupp (ps_partkey);
61create index partsupp_fk_supplier on Partsupp (ps_suppkey);
62create index customer_fk_nation on Customer (c_nationkey);
63create index orders_fk_customer on Orders (o_custkey);
64create index lineitem_fk_orders on LineItem (l_orderkey);
65create index lineitem_fk_part on LineItem (l_partkey);
66create index lineitem_fk_supplier on LineItem (l_suppkey);
67create index orders_orderdateIx on Orders (o_orderdate);
68create index lineitem_shipdateIx on LineItem (l_shipdate);
69create index lineitem_receiptdateIx on LineItem (l_receiptdate);
70
71
72
73for $c in dataset('Customer')
74for $o in dataset('Orders')
75 where $c.c_mktsegment = 'BUILDING' and $c.c_custkey = $o.o_custkey
76 for $l in dataset('LineItem')
77 where $l.l_orderkey = $o.o_orderkey and $o.o_orderdate < '1995-03-15' and $l.l_shipdate > '1995-03-15'
78/*+ hash */
79group by $l_orderkey := $l.l_orderkey, $o_orderdate := $o.o_orderdate, $o_shippriority := $o.o_shippriority
80with $l
81let $revenue := sum (
82 for $i in $l
83 return $i.l_extendedprice * (1 - $i.l_discount)
84)
85order by $revenue desc, $o_orderdate
86limit 10
87return
88{ "l_orderkey": $l_orderkey, "revenue": $revenue, "o_orderdate": $o_orderdate, "o_shippriority": $o_shippriority }
89