You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by bu...@apache.org on 2016/09/23 03:14:53 UTC
[11/51] [partial] asterixdb git commit: ASTERIXDB-1539: add aliases
for several builtin types and builtin functions.
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q01_pricing_summary_report_nt/q01_pricing_summary_report_nt.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q01_pricing_summary_report_nt/q01_pricing_summary_report_nt.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q01_pricing_summary_report_nt/q01_pricing_summary_report_nt.3.query.sqlpp
index ae276b5..19b11b2 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q01_pricing_summary_report_nt/q01_pricing_summary_report_nt.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q01_pricing_summary_report_nt/q01_pricing_summary_report_nt.3.query.sqlpp
@@ -22,25 +22,25 @@ use tpch;
set `import-private-functions` `true`;
-select element {'l_returnflag':l_returnflag,'l_linestatus':l_linestatus,'sum_qty':tpch.coll_sum((
+select element {'l_returnflag':l_returnflag,'l_linestatus':l_linestatus,'sum_qty':tpch.array_sum((
select element i.l_quantity
from l as i
- )),'sum_base_price':tpch.coll_sum((
+ )),'sum_base_price':tpch.array_sum((
select element i.l_extendedprice
from l as i
- )),'sum_disc_price':tpch.coll_sum((
+ )),'sum_disc_price':tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from l as i
- )),'sum_charge':tpch.coll_sum((
+ )),'sum_charge':tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount) * (1 + i.l_tax))
from l as i
- )),'ave_qty':tpch.coll_avg((
+ )),'ave_qty':tpch.array_avg((
select element i.l_quantity
from l as i
- )),'ave_price':tpch.coll_avg((
+ )),'ave_price':tpch.array_avg((
select element i.l_extendedprice
from l as i
- )),'ave_disc':tpch.coll_avg((
+ )),'ave_disc':tpch.array_avg((
select element i.l_discount
from l as i
)),'count_order':tpch.count(l)}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.1.ddl.sqlpp
index dd672dd..a9f2b9b 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.3.query.sqlpp
index cbb55c4..de20af3 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q02_minimum_cost_supplier/q02_minimum_cost_supplier.3.query.sqlpp
@@ -45,7 +45,7 @@ declare function tmp1() {
};
declare function tmp2() {
(
- select element {'p_partkey':p_partkey,'ps_min_supplycost':tpch.coll_min((
+ select element {'p_partkey':p_partkey,'ps_min_supplycost':tpch.array_min((
select element i.ps_supplycost
from pssrn as i
))}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.3.query.sqlpp
index bddbb53..5b9b5b0 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q03_shipping_priority_nt/q03_shipping_priority_nt.3.query.sqlpp
@@ -27,7 +27,7 @@ from Customer as c,
where (((c.c_mktsegment = 'BUILDING') and (c.c_custkey = o.o_custkey)) and ((l.l_orderkey = o.o_orderkey) and (o.o_orderdate < '1995-03-15') and (l.l_shipdate > '1995-03-15')))
/* +hash */
group by l.l_orderkey as l_orderkey,o.o_orderdate as o_orderdate,o.o_shippriority as o_shippriority
-with revenue as tpch.coll_sum((
+with revenue as tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from l as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority/q04_order_priority.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority/q04_order_priority.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority/q04_order_priority.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority/q04_order_priority.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority/q04_order_priority.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority_with_nodegroup/q04_order_priority_with_nodegroup.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority_with_nodegroup/q04_order_priority_with_nodegroup.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority_with_nodegroup/q04_order_priority_with_nodegroup.1.ddl.sqlpp
index 4aba2c4..dc314f7 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority_with_nodegroup/q04_order_priority_with_nodegroup.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q04_order_priority_with_nodegroup/q04_order_priority_with_nodegroup.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.3.query.sqlpp
index 9050001..91c8445 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q05_local_supplier_volume/q05_local_supplier_volume.3.query.sqlpp
@@ -46,7 +46,7 @@ from Customer as c,
where ((c.c_nationkey = o1.s_nationkey) and (c.c_custkey = o1.o_custkey))
/* +hash */
group by o1.n_name as n_name
-with revenue as tpch.coll_sum((
+with revenue as tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from o1 as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.1.ddl.sqlpp
index 9fe7bd2..e2ac428 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.3.query.sqlpp
index e1012b1..5246b80 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q06_forecast_revenue_change/q06_forecast_revenue_change.3.query.sqlpp
@@ -20,7 +20,7 @@
use tpch;
-{'revenue':tpch.coll_sum((
+{'revenue':tpch.array_sum((
select element (l.l_extendedprice * l.l_discount)
from LineItem as l
where ((l.l_shipdate >= '1994-01-01') and (l.l_shipdate < '1995-01-01') and (l.l_discount >= 0.05) and (l.l_discount <= 0.07) and (l.l_quantity < 24))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.3.query.sqlpp
index deeec6b..04c3d23 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q07_volume_shipping/q07_volume_shipping.3.query.sqlpp
@@ -49,7 +49,7 @@ from (
with l_year0 as tpch.`get-year`(locs.l_shipdate)
where ((locs.c_nationkey = t.c_nationkey) and (locs.s_nationkey = t.s_nationkey))
group by t.supp_nation as supp_nation,t.cust_nation as cust_nation,l_year0 as l_year
-with revenue as tpch.coll_sum((
+with revenue as tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from locs as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.3.query.sqlpp
index b9b739d..62ed625 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q08_national_market_share/q08_national_market_share.3.query.sqlpp
@@ -20,10 +20,10 @@
use tpch;
-select element {'year':year,'mkt_share':(tpch.coll_sum((
+select element {'year':year,'mkt_share':(tpch.array_sum((
select element case i.s_name = 'BRAZIL' when true then i.revenue when false then 0.0 end
from t as i
- )) / tpch.coll_sum((
+ )) / tpch.array_sum((
select element i.revenue
from t as i
)))}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.3.query.sqlpp
index 0f56186..69dc01a 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q09_product_type_profit_nt/q09_product_type_profit_nt.3.query.sqlpp
@@ -20,7 +20,7 @@
use tpch;
-select element {'nation':nation,'o_year':o_year,'sum_profit':tpch.coll_sum((
+select element {'nation':nation,'o_year':o_year,'sum_profit':tpch.array_sum((
select element pr.amount
from profit as pr
))}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.3.query.sqlpp
index 7278f81..8a66067 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item/q10_returned_item.3.query.sqlpp
@@ -34,7 +34,7 @@ from (
where ((l.l_orderkey = ocn.o_orderkey) and (l.l_returnflag = 'R'))
) as locn
group by locn.c_custkey as c_custkey,locn.c_name as c_name,locn.c_acctbal as c_acctbal,locn.c_phone as c_phone,locn.n_name as n_name,locn.c_address as c_address,locn.c_comment as c_comment
-with revenue as tpch.coll_sum((
+with revenue as tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from locn as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.3.query.sqlpp
index 7278f81..8a66067 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q10_returned_item_int64/q10_returned_item_int64.3.query.sqlpp
@@ -34,7 +34,7 @@ from (
where ((l.l_orderkey = ocn.o_orderkey) and (l.l_returnflag = 'R'))
) as locn
group by locn.c_custkey as c_custkey,locn.c_name as c_name,locn.c_acctbal as c_acctbal,locn.c_phone as c_phone,locn.n_name as n_name,locn.c_address as c_address,locn.c_comment as c_comment
-with revenue as tpch.coll_sum((
+with revenue as tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from locn as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.3.query.sqlpp
index 073835c..866c67e 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q11_important_stock/q11_important_stock.3.query.sqlpp
@@ -20,7 +20,7 @@
use tpch;
-with sum as tpch.coll_sum((
+with sum as tpch.array_sum((
select element (ps.ps_supplycost * ps.ps_availqty)
from Partsupp as ps,
(
@@ -33,7 +33,7 @@ with sum as tpch.coll_sum((
))
select element {'partkey':t1.ps_partkey,'part_value':t1.part_value}
from (
- select element {'ps_partkey':ps_partkey,'part_value':tpch.coll_sum((
+ select element {'ps_partkey':ps_partkey,'part_value':tpch.array_sum((
select element (i.ps_supplycost * i.ps_availqty)
from ps as i
))}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.3.query.sqlpp
index 395279b..bf593f6 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q12_shipping/q12_shipping.3.query.sqlpp
@@ -20,13 +20,13 @@
use tpch;
-select element {'l_shipmode':l_shipmode,'high_line_count':tpch.coll_sum((
+select element {'l_shipmode':l_shipmode,'high_line_count':tpch.array_sum((
select element case
when i.o_orderpriority = '1-URGENT' or i.o_orderpriority = '2-HIGH' then 1
else 0
end
from o as i
- )),'low_line_count':tpch.coll_sum((
+ )),'low_line_count':tpch.array_sum((
select element case
when i.o_orderpriority = '1-URGENT' or i.o_orderpriority = '2-HIGH' then 0
else 1
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.3.query.sqlpp
index 24f4f46..8c2d04b 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q13_customer_distribution/q13_customer_distribution.3.query.sqlpp
@@ -24,12 +24,12 @@ set `import-private-functions` `true`;
select element {'c_count':c_count,'custdist':custdist}
from (
- select element {'c_custkey':c_custkey,'c_count':tpch.coll_sum((
+ select element {'c_custkey':c_custkey,'c_count':tpch.array_sum((
select element i.o_orderkey_count
from co as i
))}
from (
- select element {'c_custkey':c.c_custkey,'o_orderkey_count':coll_count((
+ select element {'c_custkey':c.c_custkey,'o_orderkey_count':array_count((
select element o.o_orderkey
from Orders as o
where c.c_custkey = o.o_custkey and o.o_comment not like '%special%requests%'
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.3.query.sqlpp
index c20b6ae..467aec9 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q14_promotion_effect/q14_promotion_effect.3.query.sqlpp
@@ -20,13 +20,13 @@
use tpch;
-select element (100.0 * tpch.coll_sum((
+select element (100.0 * tpch.array_sum((
select element case
when i.p_type like 'PROMO%' then i.l_extendedprice * (1 - i.l_discount)
else 0.0
end
from lp as i
- )) / tpch.coll_sum((
+ )) / tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from lp as i
)))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.3.query.sqlpp
index fdc4fcc..c1b03bc 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q15_top_supplier/q15_top_supplier.3.query.sqlpp
@@ -22,7 +22,7 @@ use tpch;
declare function revenue() {
(
- select element {'supplier_no':l_suppkey,'total_revenue':tpch.coll_sum((
+ select element {'supplier_no':l_suppkey,'total_revenue':tpch.array_sum((
select element (i.l_extendedprice * (1 - i.l_discount))
from l as i
))}
@@ -31,7 +31,7 @@ declare function revenue() {
group by l.l_suppkey as l_suppkey
)
};
-with m as tpch.coll_max((
+with m as tpch.array_max((
select element r2.total_revenue
from tpch.revenue() as r2
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.3.query.sqlpp
index 131c8a0..2c64a98 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q16_parts_supplier_relationship/q16_parts_supplier_relationship.3.query.sqlpp
@@ -41,7 +41,7 @@ from (
group by t.p_brand as p_brand1,t.p_type as p_type1,t.p_size as p_size1,t.ps_suppkey as ps_suppkey1
) as t2
group by t2.p_brand as p_brand,t2.p_type as p_type,t2.p_size as p_size
-with supplier_cnt as coll_count((
+with supplier_cnt as array_count((
select element i.ps_suppkey
from t2 as i
))
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.1.ddl.sqlpp
index c930359..56612a4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int64,
- l_partkey : int64,
- l_suppkey : int64,
- l_linenumber : int64,
- l_quantity : int64,
+ l_orderkey : bigint,
+ l_partkey : bigint,
+ l_suppkey : bigint,
+ l_linenumber : bigint,
+ l_quantity : bigint,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int64,
- o_custkey : int64,
+ o_orderkey : bigint,
+ o_custkey : bigint,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int64,
+ o_shippriority : bigint,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int64,
+ c_custkey : bigint,
c_name : string,
c_address : string,
- c_nationkey : int64,
+ c_nationkey : bigint,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int64,
+ s_suppkey : bigint,
s_name : string,
s_address : string,
- s_nationkey : int64,
+ s_nationkey : bigint,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int64,
+ n_nationkey : bigint,
n_name : string,
- n_regionkey : int64,
+ n_regionkey : bigint,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int64,
+ r_regionkey : bigint,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int64,
+ p_partkey : bigint,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int64,
+ p_size : bigint,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int64,
- ps_suppkey : int64,
- ps_availqty : int64,
+ ps_partkey : bigint,
+ ps_suppkey : bigint,
+ ps_availqty : bigint,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.3.query.sqlpp
index 2e057d7..9316156 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_large_gby_variant/q17_large_gby_variant.3.query.sqlpp
@@ -20,34 +20,34 @@
use tpch;
-select element {'t_partkey':l_partkey,'t_count':tpch.count(l),'t_avg_quantity':(0.2 * tpch.coll_avg((
+select element {'t_partkey':l_partkey,'t_count':tpch.count(l),'t_avg_quantity':(0.2 * tpch.array_avg((
select element i.l_quantity
from l as i
- ))),'t_max_suppkey':tpch.coll_max((
+ ))),'t_max_suppkey':tpch.array_max((
select element i.l_suppkey
from l as i
- )),'t_max_linenumber':tpch.coll_max((
+ )),'t_max_linenumber':tpch.array_max((
select element i.l_linenumber
from l as i
- )),'t_avg_extendedprice':tpch.coll_avg((
+ )),'t_avg_extendedprice':tpch.array_avg((
select element i.l_extendedprice
from l as i
- )),'t_avg_discount':tpch.coll_avg((
+ )),'t_avg_discount':tpch.array_avg((
select element i.l_discount
from l as i
- )),'t_avg_tax':tpch.coll_avg((
+ )),'t_avg_tax':tpch.array_avg((
select element i.l_tax
from l as i
- )),'t_max_shipdate':tpch.coll_max((
+ )),'t_max_shipdate':tpch.array_max((
select element i.l_shipdate
from l as i
- )),'t_min_commitdate':tpch.coll_min((
+ )),'t_min_commitdate':tpch.array_min((
select element i.l_commitdate
from l as i
- )),'t_min_receiptdate':tpch.coll_min((
+ )),'t_min_receiptdate':tpch.array_min((
select element i.l_receiptdate
from l as i
- )),'t_max_comment':tpch.coll_max((
+ )),'t_max_comment':tpch.array_max((
select element i.l_comment
from l as i
))}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.1.ddl.sqlpp
index cbeb640..4e176f4 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.1.ddl.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.1.ddl.sqlpp
@@ -25,11 +25,11 @@ use tpch;
create type tpch.LineItemType as
closed {
- l_orderkey : int32,
- l_partkey : int32,
- l_suppkey : int32,
- l_linenumber : int32,
- l_quantity : int32,
+ l_orderkey : integer,
+ l_partkey : integer,
+ l_suppkey : integer,
+ l_linenumber : integer,
+ l_quantity : integer,
l_extendedprice : double,
l_discount : double,
l_tax : double,
@@ -45,23 +45,23 @@ create type tpch.LineItemType as
create type tpch.OrderType as
closed {
- o_orderkey : int32,
- o_custkey : int32,
+ o_orderkey : integer,
+ o_custkey : integer,
o_orderstatus : string,
o_totalprice : double,
o_orderdate : string,
o_orderpriority : string,
o_clerk : string,
- o_shippriority : int32,
+ o_shippriority : integer,
o_comment : string
}
create type tpch.CustomerType as
closed {
- c_custkey : int32,
+ c_custkey : integer,
c_name : string,
c_address : string,
- c_nationkey : int32,
+ c_nationkey : integer,
c_phone : string,
c_acctbal : double,
c_mktsegment : string,
@@ -70,10 +70,10 @@ create type tpch.CustomerType as
create type tpch.SupplierType as
closed {
- s_suppkey : int32,
+ s_suppkey : integer,
s_name : string,
s_address : string,
- s_nationkey : int32,
+ s_nationkey : integer,
s_phone : string,
s_acctbal : double,
s_comment : string
@@ -81,27 +81,27 @@ create type tpch.SupplierType as
create type tpch.NationType as
closed {
- n_nationkey : int32,
+ n_nationkey : integer,
n_name : string,
- n_regionkey : int32,
+ n_regionkey : integer,
n_comment : string
}
create type tpch.RegionType as
closed {
- r_regionkey : int32,
+ r_regionkey : integer,
r_name : string,
r_comment : string
}
create type tpch.PartType as
closed {
- p_partkey : int32,
+ p_partkey : integer,
p_name : string,
p_mfgr : string,
p_brand : string,
p_type : string,
- p_size : int32,
+ p_size : integer,
p_container : string,
p_retailprice : double,
p_comment : string
@@ -109,9 +109,9 @@ create type tpch.PartType as
create type tpch.PartSuppType as
closed {
- ps_partkey : int32,
- ps_suppkey : int32,
- ps_availqty : int32,
+ ps_partkey : integer,
+ ps_suppkey : integer,
+ ps_availqty : integer,
ps_supplycost : double,
ps_comment : string
}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/3b063f06/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.3.query.sqlpp
index ddbbecc..7cce670 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.3.query.sqlpp
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpch-with-index/q17_small_quantity_order_revenue/q17_small_quantity_order_revenue.3.query.sqlpp
@@ -22,7 +22,7 @@ use tpch;
declare function tmp() {
(
- select element {'t_partkey':l_partkey,'t_avg_quantity':(0.2 * tpch.coll_avg((
+ select element {'t_partkey':l_partkey,'t_avg_quantity':(0.2 * tpch.array_avg((
select element i.l_quantity
from l as i
)))}
@@ -31,7 +31,7 @@ declare function tmp() {
)
};
-select element (tpch.coll_sum((
+select element (tpch.array_sum((
select element l.l_extendedprice
from tpch.tmp() as t,
LineItem as l,