blob: 8f0cb34cf4ae71c92b5fe3366995b435dc24c714 [file] [log] [blame]
Ian Maxon857dc132015-09-25 17:13:19 -07001/*
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 */
vinayakb38b7ca42012-03-05 05:44:15 +000019drop dataverse tpch if exists;
20create dataverse tpch;
21use dataverse tpch;
22
23create type LineItemType as closed {
24 l_orderkey: int32,
25 l_partkey: int32,
26 l_suppkey: int32,
27 l_linenumber: int32,
28 l_quantity: double,
29 l_extendedprice: double,
30 l_discount: double,
31 l_tax: double,
32 l_returnflag: string,
33 l_linestatus: string,
34 l_shipdate: string,
35 l_commitdate: string,
36 l_receiptdate: string,
37 l_shipinstruct: string,
38 l_shipmode: string,
39 l_comment: string
40}
41
42create type LineIDType as closed {
43 l_orderkey: int32,
44 l_partkey: int32,
45 l_suppkey: int32
46}
47
Ian Maxonf7b64532015-12-09 17:28:18 -080048create nodegroup group1 if not exists on asterix_nc1, asterix_nc2;
vinayakb38b7ca42012-03-05 05:44:15 +000049
50create dataset LineItems_q1(LineItemType)
ramangrover29669d8f62013-02-11 06:03:32 +000051 primary key l_orderkey on group1;
vinayakb38b7ca42012-03-05 05:44:15 +000052
53create dataset LineID(LineIDType)
ramangrover29669d8f62013-02-11 06:03:32 +000054 primary key l_orderkey on group1;
vinayakb38b7ca42012-03-05 05:44:15 +000055
56create index idx_LineID_partkey on LineID(l_partkey);
57create index idx_LineID_suppkey on LineID(l_suppkey);
58
59insert into dataset LineID (
60for $l in dataset('LineItems_q1')
61// where $l.l_shipdate <= '1998-09-02'
62 return {
63 "l_orderkey": $l.l_orderkey,
64 "l_partkey": $l.l_partkey,
65 "l_suppkey": $l.l_partkey
66 }
Ian Maxon857dc132015-09-25 17:13:19 -070067);