| drop dataverse tpch if exists; |
| create dataverse tpch; |
| use dataverse tpch; |
| |
| create type LineItemType as closed { |
| l_orderkey: int32, |
| l_partkey: int32, |
| l_suppkey: int32, |
| l_linenumber: int32, |
| l_quantity: double, |
| 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 |
| } |
| |
| create type LineIDType as closed { |
| l_orderkey: int32, |
| l_partkey: int32, |
| l_suppkey: int32 |
| } |
| |
| create nodegroup group1 if not exists on nc1, nc2; |
| |
| create dataset LineItems_q1(LineItemType) |
| primary key l_orderkey on group1; |
| |
| create dataset LineID(LineIDType) |
| primary key l_orderkey on group1; |
| |
| create index idx_LineID_partkey on LineID(l_partkey); |
| create index idx_LineID_suppkey on LineID(l_suppkey); |
| |
| insert into dataset LineID ( |
| for $l in dataset('LineItems_q1') |
| // where $l.l_shipdate <= '1998-09-02' |
| return { |
| "l_orderkey": $l.l_orderkey, |
| "l_partkey": $l.l_partkey, |
| "l_suppkey": $l.l_partkey |
| } |
| ); |