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; | |
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 | |
} | |
); |