blob: 1c26a46008bbd47b9af1bb2e1bc023c414455f9d [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001drop dataverse tpch if exists;
2create dataverse tpch;
3use dataverse tpch;
4
5create type LineItemType as closed {
6 l_orderkey: int32,
7 l_partkey: int32,
8 l_suppkey: int32,
9 l_linenumber: int32,
10 l_quantity: double,
11 l_extendedprice: double,
12 l_discount: double,
13 l_tax: double,
14 l_returnflag: string,
15 l_linestatus: string,
16 l_shipdate: string,
17 l_commitdate: string,
18 l_receiptdate: string,
19 l_shipinstruct: string,
20 l_shipmode: string,
21 l_comment: string
22}
23
24create type LineIDType as closed {
25 l_orderkey: int32,
26 l_partkey: int32,
27 l_suppkey: int32
28}
29
30create nodegroup group1 if not exists on nc1, nc2;
31
32create dataset LineItems_q1(LineItemType)
ramangrover29669d8f62013-02-11 06:03:32 +000033 primary key l_orderkey on group1;
vinayakb38b7ca42012-03-05 05:44:15 +000034
35create dataset LineID(LineIDType)
ramangrover29669d8f62013-02-11 06:03:32 +000036 primary key l_orderkey on group1;
vinayakb38b7ca42012-03-05 05:44:15 +000037
38insert into dataset LineID (
39for $l in dataset('LineItems_q1')
40// where $l.l_shipdate <= '1998-09-02'
41 return {
42 "l_orderkey": $l.l_orderkey,
43 "l_partkey": $l.l_partkey,
44 "l_suppkey": $l.l_partkey
45 }
46);