blob: 97bc8dfea6bfde7b6bd712669712db9f08f59f64 [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
38create index idx_LineID_partkey on LineID(l_partkey);
39create index idx_LineID_suppkey on LineID(l_suppkey);
40
41insert into dataset LineID (
42for $l in dataset('LineItems_q1')
43// where $l.l_shipdate <= '1998-09-02'
44 return {
45 "l_orderkey": $l.l_orderkey,
46 "l_partkey": $l.l_partkey,
47 "l_suppkey": $l.l_partkey
48 }
49);