Yingyi Bu | 8f6301f | 2016-03-05 01:10:05 -0800 | [diff] [blame] | 1 | /* |
| 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 | |
| 20 | drop dataverse tpch if exists; |
| 21 | create dataverse tpch; |
| 22 | use dataverse tpch; |
| 23 | |
| 24 | create 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 | |
| 27 | create 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 | |
| 30 | create 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 | |
| 33 | create 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 | |
| 36 | create type PartSuppType as |
| 37 | { ps_partkey: int64, ps_suppkey: int64, ps_availqty: int32, ps_supplycost: double, ps_comment: string } |
| 38 | |
| 39 | create 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 | |
| 42 | create type NationType as |
| 43 | { n_nationkey: int32, n_name: string, n_regionkey: int32, n_comment: string } |
| 44 | |
| 45 | create type RegionType as |
| 46 | { r_regionkey: int32, r_name: string, r_comment: string } |
| 47 | |
| 48 | create dataset LineItem(LineItemType) primary key l_orderkey, l_linenumber; |
| 49 | create dataset Orders(OrderType) primary key o_orderkey; |
| 50 | create dataset Customer(CustomerType) primary key c_custkey; |
| 51 | create dataset Part(PartType) primary key p_partkey; |
| 52 | create dataset Partsupp(PartSuppType) primary key ps_partkey, ps_suppkey; |
| 53 | create dataset Supplier(SupplierType) primary key s_suppkey; |
| 54 | create dataset Region(RegionType) primary key r_regionkey; |
| 55 | create dataset Nation(NationType) primary key n_nationkey; |
| 56 | |
| 57 | |
| 58 | create index nation_fk_region on Nation(n_regionkey); |
| 59 | create index supplier_fk_nation on Supplier (s_nationkey); |
| 60 | create index partsupp_fk_part on Partsupp (ps_partkey); |
| 61 | create index partsupp_fk_supplier on Partsupp (ps_suppkey); |
| 62 | create index customer_fk_nation on Customer (c_nationkey); |
| 63 | create index orders_fk_customer on Orders (o_custkey); |
| 64 | create index lineitem_fk_orders on LineItem (l_orderkey); |
| 65 | create index lineitem_fk_part on LineItem (l_partkey); |
| 66 | create index lineitem_fk_supplier on LineItem (l_suppkey); |
| 67 | create index orders_orderdateIx on Orders (o_orderdate); |
| 68 | create index lineitem_shipdateIx on LineItem (l_shipdate); |
| 69 | create index lineitem_receiptdateIx on LineItem (l_receiptdate); |
| 70 | |
| 71 | |
| 72 | |
| 73 | for $c in dataset('Customer') |
| 74 | for $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 */ |
| 79 | group by $l_orderkey := $l.l_orderkey, $o_orderdate := $o.o_orderdate, $o_shippriority := $o.o_shippriority |
| 80 | with $l |
| 81 | let $revenue := sum ( |
| 82 | for $i in $l |
| 83 | return $i.l_extendedprice * (1 - $i.l_discount) |
| 84 | ) |
| 85 | order by $revenue desc, $o_orderdate |
| 86 | limit 10 |
| 87 | return |
| 88 | { "l_orderkey": $l_orderkey, "revenue": $revenue, "o_orderdate": $o_orderdate, "o_shippriority": $o_shippriority } |
| 89 | |