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/10/04 20:34:47 UTC
[2/6] asterixdb git commit: Add test TPC-DS data and 35 TPC-DS
queries.
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.2.update.sqlpp
new file mode 100644
index 0000000..a673f5b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.2.update.sqlpp
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset household_demographics using localfs ((`path`=`asterix_nc1://data/tpcds/household_demographics.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset time_dim using localfs ((`path`=`asterix_nc1://data/tpcds/time_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset store_sales using localfs ((`path`=`asterix_nc1://data/tpcds/store_sales.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset store using localfs ((`path`=`asterix_nc1://data/tpcds/store.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.3.query.sqlpp
new file mode 100644
index 0000000..455eab7
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q88/q88.3.query.sqlpp
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+SELECT VALUE {"h8_30_to_9" : COLL_COUNT((select 1
+ FROM store_sales ss1, household_demographics , time_dim, store s1
+ WHERE ss1.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss1.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss1.ss_store_sk = s1.s_store_sk
+ AND time_dim.t_hour = 8
+ AND time_dim.t_minute >= 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s1.s_store_name = 'ese')), "h9_to_9_30": COLL_COUNT((select 1
+ FROM store_sales ss2, household_demographics , time_dim, store s2
+ WHERE ss2.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss2.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss2.ss_store_sk = s2.s_store_sk
+ AND time_dim.t_hour = 9
+ AND time_dim.t_minute < 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s2.s_store_name = 'ese')), "h9_30_to_10": COLL_COUNT((select 1
+ FROM store_sales ss3, household_demographics , time_dim, store s3
+ WHERE ss3.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss3.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss3.ss_store_sk = s3.s_store_sk
+ AND time_dim.t_hour = 9
+ AND time_dim.t_minute >= 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s3.s_store_name = 'ese')), "h10_to_10_30": COLL_COUNT((select 1
+ FROM store_sales ss4, household_demographics , time_dim, store s4
+ WHERE ss4.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss4.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss4.ss_store_sk = s4.s_store_sk
+ AND time_dim.t_hour = 10
+ AND time_dim.t_minute < 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s4.s_store_name = 'ese')), "h10_30_to_11": COLL_COUNT( (select 1
+ FROM store_sales ss5, household_demographics , time_dim, store s5
+ WHERE ss5.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss5.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss5.ss_store_sk = s5.s_store_sk
+ AND time_dim.t_hour = 10
+ AND time_dim.t_minute >= 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s5.s_store_name = 'ese')), "h11_to_11_30": COLL_COUNT((select 1
+ FROM store_sales ss6, household_demographics , time_dim, store s6
+ WHERE ss6.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss6.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss6.ss_store_sk = s6.s_store_sk
+ AND time_dim.t_hour = 11
+ AND time_dim.t_minute < 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s6.s_store_name = 'ese')), "h11_30_to_12": COLL_COUNT((select 1
+ FROM store_sales ss7, household_demographics , time_dim, store s7
+ WHERE ss7.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss7.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss7.ss_store_sk = s7.s_store_sk
+ AND time_dim.t_hour = 11
+ AND time_dim.t_minute >= 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s7.s_store_name = 'ese')), "h12_to_12_30": COLL_COUNT((select 1
+ FROM store_sales ss8, household_demographics , time_dim, store s8
+ WHERE ss8.ss_sold_time_sk = time_dim.t_time_sk
+ AND ss8.ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss8.ss_store_sk = s8.s_store_sk
+ AND time_dim.t_hour = 12
+ AND time_dim.t_minute < 30
+ AND ((household_demographics.hd_dep_count = 3 AND household_demographics.hd_vehicle_count<=3+2) or
+ (household_demographics.hd_dep_count = 0 AND household_demographics.hd_vehicle_count<=0+2) or
+ (household_demographics.hd_dep_count = 1 AND household_demographics.hd_vehicle_count<=1+2))
+ AND s8.s_store_name = 'ese'))};
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.1.ddl.sqlpp
new file mode 100644
index 0000000..5497be1
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.1.ddl.sqlpp
@@ -0,0 +1,195 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+drop dataverse tpcds if exists;
+create dataverse tpcds;
+
+use tpcds;
+
+
+
+create type tpcds.customer_address_type as closed {
+ ca_address_sk : bigint,
+ ca_address_id : string,
+ ca_street_number : string?,
+ ca_street_name : string?,
+ ca_street_type : string?,
+ ca_suite_number : string?,
+ ca_city : string?,
+ ca_county : string?,
+ ca_state : string?,
+ ca_zip : string?,
+ ca_country : string?,
+ ca_gmt_offset : double?,
+ ca_location_type : string?
+ }
+
+create type tpcds.call_center_type as
+ closed {
+ cc_call_center_sk : bigint,
+ cc_call_center_id : string,
+ cc_rec_start_date : string?,
+ cc_rec_end_date : string?,
+ cc_closed_date_sk : bigint?,
+ cc_open_date_sk : bigint?,
+ cc_name : string?,
+ cc_class : string?,
+ cc_employees : bigint?,
+ cc_sq_ft : bigint?,
+ cc_hours : string?,
+ cc_manager : string?,
+ cc_mkt_id : bigint?,
+ cc_mkt_class : string?,
+ cc_mkt_desc : string?,
+ cc_market_manager : string?,
+ cc_division : bigint?,
+ cc_division_name : string?,
+ cc_company : bigint?,
+ cc_company_name : string?,
+ cc_street_number : bigint?,
+ cc_street_name : string?,
+ cc_street_type : string?,
+ cc_suite_number : string?,
+ cc_city : string?,
+ cc_county : string?,
+ cc_state : string?,
+ cc_zip : string?,
+ cc_country : string?,
+ cc_gmt_offset : double?,
+ cc_tax_percentage : double?
+}
+
+create type tpcds.household_demographics_type as
+ closed {
+ hd_demo_sk : bigint,
+ hd_income_band_sk : bigint?,
+ hd_buy_potential : string?,
+ hd_dep_count : bigint?,
+ hd_vehicle_count : bigint?
+}
+create type tpcds.customer_demographics_type as
+ closed {
+ cd_demo_sk : bigint,
+ cd_gender : string?,
+ cd_marital_status : string?,
+ cd_education_status : string?,
+ cd_purchase_estimate : bigint?,
+ cd_credit_rating : string?,
+ cd_dep_count : bigint?,
+ cd_dep_employed_count : bigint?,
+ cd_dep_college_count : bigint?
+}
+create type tpcds.date_dim_type as
+ closed {
+ d_date_sk : bigint,
+ d_date_id : string,
+ d_date : string?,
+ d_month_seq : bigint?,
+ d_week_seq : bigint?,
+ d_quarter_seq : bigint?,
+ d_year : bigint? ,
+ d_dow : bigint? ,
+ d_moy : bigint?,
+ d_dom : bigint?,
+ d_qoy : bigint?,
+ d_fy_year : bigint?,
+ d_fy_quarter_seq : bigint?,
+ d_fy_week_seq : bigint?,
+ d_day_name : string?,
+ d_quarter_name : string?,
+ d_holiday : string?,
+ d_weekend : string?,
+ d_following_holiday : string?,
+ d_first_dom : bigint?,
+ d_last_dom : bigint?,
+ d_same_day_ly : bigint?,
+ d_same_day_lq : bigint?,
+ d_current_day : string?,
+ d_current_week : string?,
+ d_current_month : string?,
+ d_current_quarter : string?,
+ d_current_year : string?
+}
+
+create type tpcds.catalog_returns_type as
+ closed {
+ cr_returned_date_sk : bigint?,
+ cr_returned_time_sk : bigint?,
+ cr_item_sk : bigint,
+ cr_refunded_customer_sk : bigint?,
+ cr_refunded_cdemo_sk : bigint?,
+ cr_refunded_hdemo_sk : bigint?,
+ cr_refunded_addr_sk : bigint?,
+ cr_returning_customer_sk : bigint?,
+ cr_returning_cdemo_sk : bigint?,
+ cr_returning_hdemo_sk : bigint?,
+ cr_returning_addr_sk : bigint?,
+ cr_call_center_sk : bigint?,
+ cr_catalog_page_sk : bigint?,
+ cr_ship_mode_sk : bigint?,
+ cr_warehouse_sk : bigint?,
+ cr_reason_sk : bigint?,
+ cr_order_number : bigint,
+ cr_return_quantity : bigint?,
+ cr_return_amount : double?,
+ cr_return_tax : double?,
+ cr_return_amt_inc_tax : double?,
+ cr_fee : double?,
+ cr_return_ship_cost : double?,
+ cr_refunded_cash : double?,
+ cr_reversed_charge : double?,
+ cr_store_credit : double?,
+ cr_net_loss : double?
+}
+
+create type tpcds.customer_type as
+ closed {
+ c_customer_sk : bigint,
+ c_customer_id : string,
+ c_current_cdemo_sk : bigint?,
+ c_current_hdemo_sk : bigint?,
+ c_current_addr_sk : bigint?,
+ c_first_shipto_date_sk : bigint?,
+ c_first_sales_date_sk : bigint?,
+ c_salutation : string?,
+ c_first_name : string?,
+ c_last_name : string?,
+ c_preferred_cust_flag : string?,
+ c_birth_day : bigint?,
+ c_birth_month : bigint?,
+ c_birth_year : bigint?,
+ c_birth_country : string?,
+ c_login : string?,
+ c_email_address : string?,
+ c_last_review_date : string?
+}
+
+create dataset customer_address(customer_address_type) primary key ca_address_sk;
+
+create dataset call_center (call_center_type) primary key cc_call_center_sk;
+
+create dataset household_demographics (household_demographics_type) primary key hd_demo_sk;
+
+create dataset customer_demographics(customer_demographics_type) primary key cd_demo_sk;
+
+create dataset date_dim(date_dim_type) primary key d_date_sk;
+
+create dataset catalog_returns (catalog_returns_type) primary key cr_item_sk, cr_order_number;
+
+create dataset customer (customer_type) primary key c_customer_sk;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.2.update.sqlpp
new file mode 100644
index 0000000..4599485
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.2.update.sqlpp
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset customer_address using localfs ((`path`=`asterix_nc1://data/tpcds/customer_address.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset call_center using localfs ((`path`=`asterix_nc1://data/tpcds/call_center.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset household_demographics using localfs ((`path`=`asterix_nc1://data/tpcds/household_demographics.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset customer_demographics using localfs ((`path`=`asterix_nc1://data/tpcds/customer_demographics.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset date_dim using localfs ((`path`=`asterix_nc1://data/tpcds/date_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset catalog_returns using localfs ((`path`=`asterix_nc1://data/tpcds/catalog_returns.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset customer using localfs ((`path`=`asterix_nc1://data/tpcds/customer.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.3.query.sqlpp
new file mode 100644
index 0000000..9ce8ffe
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q91/q91.3.query.sqlpp
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+SELECT
+ cc_call_center_id Call_Center,
+ cc_name Call_Center_Name,
+ cc_manager Manager,
+ SUM(cr_net_loss) Returns_Loss
+FROM
+ call_center,
+ catalog_returns,
+ date_dim,
+ customer,
+ customer_address,
+ customer_demographics,
+ household_demographics
+WHERE
+ cr_call_center_sk = cc_call_center_sk
+AND cr_returned_date_sk = d_date_sk
+AND cr_returning_customer_sk= c_customer_sk
+AND cd_demo_sk = c_current_cdemo_sk
+AND hd_demo_sk = c_current_hdemo_sk
+AND ca_address_sk = c_current_addr_sk
+AND d_year = 1999
+AND d_moy = 11
+AND ( (cd_marital_status = 'M' AND cd_education_status = 'Unknown')
+ OR (cd_marital_status = 'W' AND cd_education_status = 'Advanced Degree'))
+AND hd_buy_potential like '0-500%'
+AND ca_gmt_offset = -7
+GROUP BY cc_call_center_id,cc_name,cc_manager,cd_marital_status,cd_education_status
+ORDER BY SUM(cr_net_loss) desc;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.1.ddl.sqlpp
new file mode 100644
index 0000000..027a556
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.1.ddl.sqlpp
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+drop dataverse tpcds if exists;
+create dataverse tpcds;
+
+use tpcds;
+
+
+
+create type tpcds.customer_address_type as closed {
+ ca_address_sk : bigint,
+ ca_address_id : string,
+ ca_street_number : string?,
+ ca_street_name : string?,
+ ca_street_type : string?,
+ ca_suite_number : string?,
+ ca_city : string?,
+ ca_county : string?,
+ ca_state : string?,
+ ca_zip : string?,
+ ca_country : string?,
+ ca_gmt_offset : double?,
+ ca_location_type : string?
+ }
+
+create type tpcds.web_sales_type as
+ closed {
+ ws_sold_date_sk : bigint?,
+ ws_sold_time_sk : bigint?,
+ ws_ship_date_sk : bigint?,
+ ws_item_sk : bigint,
+ ws_bill_customer_sk : bigint?,
+ ws_bill_cdemo_sk : bigint?,
+ ws_bill_hdemo_sk : bigint?,
+ ws_bill_addr_sk : bigint?,
+ ws_ship_customer_sk : bigint?,
+ ws_ship_cdemo_sk : bigint?,
+ ws_ship_hdemo_sk : bigint?,
+ ws_ship_addr_sk : bigint?,
+ ws_web_page_sk : bigint?,
+ ws_web_site_sk : bigint?,
+ ws_ship_mode_sk : bigint?,
+ ws_warehouse_sk : bigint?,
+ ws_promo_sk : bigint?,
+ ws_order_number : bigint,
+ ws_quantity : bigint?,
+ ws_wholesale_cost : double?,
+ ws_list_price : double?,
+ ws_sales_price : double?,
+ ws_ext_discount_amt : double?,
+ ws_ext_sales_price : double?,
+ ws_ext_wholesale_cost : double?,
+ ws_ext_list_price : double?,
+ ws_ext_tax : double?,
+ ws_coupon_amt : double?,
+ ws_ext_ship_cost : double?,
+ ws_net_paid : double?,
+ ws_net_paid_inc_tax : double?,
+ ws_net_paid_inc_ship : double?,
+ ws_net_paid_inc_ship_tax : double?,
+ ws_net_profit : double?
+}
+
+create type tpcds.date_dim_type as
+ closed {
+ d_date_sk : bigint,
+ d_date_id : string,
+ d_date : string?,
+ d_month_seq : bigint?,
+ d_week_seq : bigint?,
+ d_quarter_seq : bigint?,
+ d_year : bigint? ,
+ d_dow : bigint? ,
+ d_moy : bigint?,
+ d_dom : bigint?,
+ d_qoy : bigint?,
+ d_fy_year : bigint?,
+ d_fy_quarter_seq : bigint?,
+ d_fy_week_seq : bigint?,
+ d_day_name : string?,
+ d_quarter_name : string?,
+ d_holiday : string?,
+ d_weekend : string?,
+ d_following_holiday : string?,
+ d_first_dom : bigint?,
+ d_last_dom : bigint?,
+ d_same_day_ly : bigint?,
+ d_same_day_lq : bigint?,
+ d_current_day : string?,
+ d_current_week : string?,
+ d_current_month : string?,
+ d_current_quarter : string?,
+ d_current_year : string?
+}
+
+create type tpcds.web_returns_type as
+ closed {
+ wr_returned_date_sk : bigint?,
+ wr_returned_time_sk : bigint?,
+ wr_item_sk : bigint,
+ wr_refunded_customer_sk : bigint?,
+ wr_refunded_cdemo_sk : bigint?,
+ wr_refunded_hdemo_sk : bigint?,
+ wr_refunded_addr_sk : bigint?,
+ wr_returning_customer_sk : bigint?,
+ wr_returning_cdemo_sk : bigint?,
+ wr_returning_hdemo_sk : bigint?,
+ wr_returning_addr_sk : bigint?,
+ wr_web_page_sk : bigint?,
+ wr_reason_sk : bigint?,
+ wr_order_number : bigint,
+ wr_return_quantity : bigint?,
+ wr_return_amt : double?,
+ wr_return_tax : double?,
+ wr_return_amt_inc_tax : double?,
+ wr_fee : double?,
+ wr_return_ship_cost: double?,
+ wr_refunded_cash: double?,
+ wr_reversed_charge: double?,
+ wr_account_credit: double?,
+ wr_net_loss: double?
+}
+
+create type tpcds.web_site_type as
+ closed {
+ web_site_sk: bigint,
+ web_site_id: string,
+ web_rec_start_date: string?,
+ web_rec_end_date: string?,
+ web_name: string?,
+ web_open_date_sk: bigint?,
+ web_close_date_sk: bigint?,
+ web_class: string?,
+ web_manager: string?,
+ web_mkt_id: bigint?,
+ web_mkt_class: string?,
+ web_mkt_desc: string?,
+ web_market_manager: string?,
+ web_company_id: bigint?,
+ web_company_name: string?,
+ web_street_number: string?,
+ web_street_name: string?,
+ web_street_type: string?,
+ web_suite_number: string?,
+ web_city: string?,
+ web_county: string?,
+ web_state: string?,
+ web_zip: string?,
+ web_country: string?,
+ web_gmt_offset: double?,
+ web_tax_percentage: double?
+}
+
+create dataset customer_address(customer_address_type) primary key ca_address_sk;
+
+create dataset web_sales (web_sales_type) primary key ws_item_sk, ws_order_number;
+
+create dataset date_dim(date_dim_type) primary key d_date_sk;
+
+create dataset web_returns (web_returns_type) primary key wr_item_sk, wr_order_number;
+
+create dataset web_site (web_site_type) primary key web_site_sk;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.2.update.sqlpp
new file mode 100644
index 0000000..08a8f79
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.2.update.sqlpp
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset customer_address using localfs ((`path`=`asterix_nc1://data/tpcds/customer_address.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_sales using localfs ((`path`=`asterix_nc1://data/tpcds/web_sales.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset date_dim using localfs ((`path`=`asterix_nc1://data/tpcds/date_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_returns using localfs ((`path`=`asterix_nc1://data/tpcds/web_returns.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_site using localfs ((`path`=`asterix_nc1://data/tpcds/web_site.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.3.query.sqlpp
new file mode 100644
index 0000000..9de99d7
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q94/q94.3.query.sqlpp
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+SELECT
+ COUNT(wsnondup.ws_order_number) order_count,
+ SUM(ws_ext_ship_cost) total_shipping_cost,
+ SUM(ws_net_profit) total_net_profit
+FROM
+ (SELECT ws_order_number
+ FROM web_sales
+ GROUP BY ws_order_number) AS wsnondup,
+ web_sales as ws1,
+ date_dim,
+ customer_address,
+ web_site
+WHERE
+ date(d_date) >= date('1999-05-01')
+AND date(d_date) <= date('1999-06-29')
+AND ws1.ws_ship_date_sk = d_date_sk
+AND ws1.ws_ship_addr_sk = ca_address_sk
+AND ca_state = 'TX'
+AND ws1.ws_web_site_sk = web_site_sk
+AND web_company_name = 'pri'
+AND EXISTS (SELECT *
+ FROM web_sales ws2
+ WHERE ws1.ws_order_number = ws2.ws_order_number
+ AND ws1.ws_warehouse_sk != ws2.ws_warehouse_sk)
+AND NOT EXISTS (select *
+ from web_returns wr1
+ where ws1.ws_order_number = wr1.wr_order_number)
+ORDER BY COUNT(wsnondup.ws_order_number)
+LIMIT 100;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.1.ddl.sqlpp
new file mode 100644
index 0000000..027a556
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.1.ddl.sqlpp
@@ -0,0 +1,179 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+drop dataverse tpcds if exists;
+create dataverse tpcds;
+
+use tpcds;
+
+
+
+create type tpcds.customer_address_type as closed {
+ ca_address_sk : bigint,
+ ca_address_id : string,
+ ca_street_number : string?,
+ ca_street_name : string?,
+ ca_street_type : string?,
+ ca_suite_number : string?,
+ ca_city : string?,
+ ca_county : string?,
+ ca_state : string?,
+ ca_zip : string?,
+ ca_country : string?,
+ ca_gmt_offset : double?,
+ ca_location_type : string?
+ }
+
+create type tpcds.web_sales_type as
+ closed {
+ ws_sold_date_sk : bigint?,
+ ws_sold_time_sk : bigint?,
+ ws_ship_date_sk : bigint?,
+ ws_item_sk : bigint,
+ ws_bill_customer_sk : bigint?,
+ ws_bill_cdemo_sk : bigint?,
+ ws_bill_hdemo_sk : bigint?,
+ ws_bill_addr_sk : bigint?,
+ ws_ship_customer_sk : bigint?,
+ ws_ship_cdemo_sk : bigint?,
+ ws_ship_hdemo_sk : bigint?,
+ ws_ship_addr_sk : bigint?,
+ ws_web_page_sk : bigint?,
+ ws_web_site_sk : bigint?,
+ ws_ship_mode_sk : bigint?,
+ ws_warehouse_sk : bigint?,
+ ws_promo_sk : bigint?,
+ ws_order_number : bigint,
+ ws_quantity : bigint?,
+ ws_wholesale_cost : double?,
+ ws_list_price : double?,
+ ws_sales_price : double?,
+ ws_ext_discount_amt : double?,
+ ws_ext_sales_price : double?,
+ ws_ext_wholesale_cost : double?,
+ ws_ext_list_price : double?,
+ ws_ext_tax : double?,
+ ws_coupon_amt : double?,
+ ws_ext_ship_cost : double?,
+ ws_net_paid : double?,
+ ws_net_paid_inc_tax : double?,
+ ws_net_paid_inc_ship : double?,
+ ws_net_paid_inc_ship_tax : double?,
+ ws_net_profit : double?
+}
+
+create type tpcds.date_dim_type as
+ closed {
+ d_date_sk : bigint,
+ d_date_id : string,
+ d_date : string?,
+ d_month_seq : bigint?,
+ d_week_seq : bigint?,
+ d_quarter_seq : bigint?,
+ d_year : bigint? ,
+ d_dow : bigint? ,
+ d_moy : bigint?,
+ d_dom : bigint?,
+ d_qoy : bigint?,
+ d_fy_year : bigint?,
+ d_fy_quarter_seq : bigint?,
+ d_fy_week_seq : bigint?,
+ d_day_name : string?,
+ d_quarter_name : string?,
+ d_holiday : string?,
+ d_weekend : string?,
+ d_following_holiday : string?,
+ d_first_dom : bigint?,
+ d_last_dom : bigint?,
+ d_same_day_ly : bigint?,
+ d_same_day_lq : bigint?,
+ d_current_day : string?,
+ d_current_week : string?,
+ d_current_month : string?,
+ d_current_quarter : string?,
+ d_current_year : string?
+}
+
+create type tpcds.web_returns_type as
+ closed {
+ wr_returned_date_sk : bigint?,
+ wr_returned_time_sk : bigint?,
+ wr_item_sk : bigint,
+ wr_refunded_customer_sk : bigint?,
+ wr_refunded_cdemo_sk : bigint?,
+ wr_refunded_hdemo_sk : bigint?,
+ wr_refunded_addr_sk : bigint?,
+ wr_returning_customer_sk : bigint?,
+ wr_returning_cdemo_sk : bigint?,
+ wr_returning_hdemo_sk : bigint?,
+ wr_returning_addr_sk : bigint?,
+ wr_web_page_sk : bigint?,
+ wr_reason_sk : bigint?,
+ wr_order_number : bigint,
+ wr_return_quantity : bigint?,
+ wr_return_amt : double?,
+ wr_return_tax : double?,
+ wr_return_amt_inc_tax : double?,
+ wr_fee : double?,
+ wr_return_ship_cost: double?,
+ wr_refunded_cash: double?,
+ wr_reversed_charge: double?,
+ wr_account_credit: double?,
+ wr_net_loss: double?
+}
+
+create type tpcds.web_site_type as
+ closed {
+ web_site_sk: bigint,
+ web_site_id: string,
+ web_rec_start_date: string?,
+ web_rec_end_date: string?,
+ web_name: string?,
+ web_open_date_sk: bigint?,
+ web_close_date_sk: bigint?,
+ web_class: string?,
+ web_manager: string?,
+ web_mkt_id: bigint?,
+ web_mkt_class: string?,
+ web_mkt_desc: string?,
+ web_market_manager: string?,
+ web_company_id: bigint?,
+ web_company_name: string?,
+ web_street_number: string?,
+ web_street_name: string?,
+ web_street_type: string?,
+ web_suite_number: string?,
+ web_city: string?,
+ web_county: string?,
+ web_state: string?,
+ web_zip: string?,
+ web_country: string?,
+ web_gmt_offset: double?,
+ web_tax_percentage: double?
+}
+
+create dataset customer_address(customer_address_type) primary key ca_address_sk;
+
+create dataset web_sales (web_sales_type) primary key ws_item_sk, ws_order_number;
+
+create dataset date_dim(date_dim_type) primary key d_date_sk;
+
+create dataset web_returns (web_returns_type) primary key wr_item_sk, wr_order_number;
+
+create dataset web_site (web_site_type) primary key web_site_sk;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.2.update.sqlpp
new file mode 100644
index 0000000..08a8f79
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.2.update.sqlpp
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset customer_address using localfs ((`path`=`asterix_nc1://data/tpcds/customer_address.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_sales using localfs ((`path`=`asterix_nc1://data/tpcds/web_sales.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset date_dim using localfs ((`path`=`asterix_nc1://data/tpcds/date_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_returns using localfs ((`path`=`asterix_nc1://data/tpcds/web_returns.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset web_site using localfs ((`path`=`asterix_nc1://data/tpcds/web_site.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.3.query.sqlpp
new file mode 100644
index 0000000..e32122f
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q95/q95.3.query.sqlpp
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+WITH ws_wh AS
+(SELECT ws1.ws_order_number,ws1.ws_warehouse_sk wh1,ws2.ws_warehouse_sk wh2
+ FROM web_sales ws1,web_sales ws2
+ WHERE ws1.ws_order_number = ws2.ws_order_number
+ AND ws1.ws_warehouse_sk != ws2.ws_warehouse_sk)
+ SELECT
+ count(ws_order_number) AS order_count
+ , sum(ws_ext_ship_cost) AS total_shipping_cost
+ ,sum(ws_net_profit) AS total_net_profit
+ FROM
+ (
+ SELECT
+ distinct ws_order_number
+ ,ws_ext_ship_cost
+ ,ws_net_profit
+FROM
+ web_sales ws1
+ ,date_dim
+ ,customer_address
+ ,web_site
+WHERE
+ date(d_date) >= date('1999-05-01')
+AND date(d_date) <= date('1999-06-30')
+AND ws1.ws_ship_date_sk = d_date_sk
+AND ws1.ws_ship_addr_sk = ca_address_sk
+AND ca_state = 'TX'
+AND ws1.ws_web_site_sk = web_site_sk
+AND web_company_name = 'pri'
+AND ws1.ws_order_number IN (SELECT VALUE ws_wh.ws_order_number
+ FROM ws_wh)
+AND ws1.ws_order_number IN (SELECT VALUE wr_order_number
+ FROM web_returns,ws_wh
+ WHERE wr_order_number = ws_wh.ws_order_number)
+) t1
+ORDER BY COUNT(ws_order_number)
+LIMIT 100;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.1.ddl.sqlpp
new file mode 100644
index 0000000..342fecd
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.1.ddl.sqlpp
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+drop dataverse tpcds if exists;
+create dataverse tpcds;
+
+use tpcds;
+
+
+create type tpcds.household_demographics_type as
+ closed {
+ hd_demo_sk : bigint,
+ hd_income_band_sk : bigint?,
+ hd_buy_potential : string?,
+ hd_dep_count : bigint?,
+ hd_vehicle_count : bigint?
+}
+create type tpcds.time_dim_type as
+ closed {
+ t_time_sk : bigint,
+ t_time_id : string,
+ t_time : bigint?,
+ t_hour : bigint?,
+ t_minute : bigint?,
+ t_second : bigint?,
+ t_am_pm : string?,
+ t_shift : string?,
+ t_sub_shift : string?,
+ t_meal_time : string?
+}
+create type tpcds.store_sales_type as
+ closed {
+ ss_sold_date_sk: bigint?,
+ ss_sold_time_sk: bigint?,
+ ss_item_sk: bigint,
+ ss_customer_sk: bigint?,
+ ss_cdemo_sk: bigint?,
+ ss_hdemo_sk: bigint?,
+ ss_addr_sk: bigint?,
+ ss_store_sk: bigint?,
+ ss_promo_sk: bigint?,
+ ss_ticket_number: bigint,
+ ss_quantity: bigint?,
+ ss_wholesale_cost: double?,
+ ss_list_price: double?,
+ ss_sales_price: double?,
+ ss_ext_discount_amt: double?,
+ ss_ext_sales_price: double?,
+ ss_ext_wholesale_cost: double?,
+ ss_ext_list_price: double?,
+ ss_ext_tax: double?,
+ ss_coupon_amt: double?,
+ ss_net_paid: double?,
+ ss_net_paid_inc_tax: double?,
+ ss_net_profit: double?
+}
+
+create type tpcds.store_type as
+ closed {
+ s_store_sk : bigint,
+ s_store_id : string,
+ s_rec_start_date : string?,
+ s_rec_end_date : string?,
+ s_closed_date_sk : bigint?,
+ s_store_name : string?,
+ s_number_employees : bigint?,
+ s_floor_space : bigint?,
+ s_hours : string?,
+ s_manager : string?,
+ s_market_id : bigint?,
+ s_geography_class : string?,
+ s_market_desc : string?,
+ s_market_manager : string?,
+ s_division_id : bigint?,
+ s_division_name : string?,
+ s_company_id : bigint?,
+ s_company_name : string?,
+ s_street_number : string?,
+ s_street_name : string?,
+ s_street_type : string?,
+ s_suite_number : string?,
+ s_city : string?,
+ s_county : string?,
+ s_state : string?,
+ s_zip : string?,
+ s_country : string?,
+ s_gmt_offset : double?,
+ s_tax_precentage : double?
+}
+
+create dataset household_demographics (household_demographics_type) primary key hd_demo_sk;
+
+create dataset tpcds.time_dim(time_dim_type) primary key t_time_sk
+
+create dataset store_sales (store_sales_type) primary key ss_item_sk, ss_ticket_number;
+
+create dataset store (store_type) primary key s_store_sk;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.2.update.sqlpp
new file mode 100644
index 0000000..a673f5b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.2.update.sqlpp
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset household_demographics using localfs ((`path`=`asterix_nc1://data/tpcds/household_demographics.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset time_dim using localfs ((`path`=`asterix_nc1://data/tpcds/time_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset store_sales using localfs ((`path`=`asterix_nc1://data/tpcds/store_sales.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset store using localfs ((`path`=`asterix_nc1://data/tpcds/store.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.3.query.sqlpp
new file mode 100644
index 0000000..1fa8c67
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q96/q96.3.query.sqlpp
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+SELECT COUNT(soldaftertable)
+FROM
+(SELECT *
+FROM store_sales,
+ household_demographics,
+ time_dim, store
+WHERE ss_sold_time_sk = time_dim.t_time_sk
+ AND ss_hdemo_sk = household_demographics.hd_demo_sk
+ AND ss_store_sk = s_store_sk
+ AND time_dim.t_hour = 8
+ AND time_dim.t_minute >= 30
+ AND household_demographics.hd_dep_count = 5
+ AND store.s_store_name = 'ese'
+) AS soldaftertable
+ORDER BY COUNT(soldaftertable)
+LIMIT 100;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.1.ddl.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.1.ddl.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.1.ddl.sqlpp
new file mode 100644
index 0000000..4769c9c
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.1.ddl.sqlpp
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+drop dataverse tpcds if exists;
+create dataverse tpcds;
+
+use tpcds;
+
+
+create type tpcds.item_type as
+ closed {
+ i_item_sk : bigint,
+ i_item_id : string,
+ i_rec_start_date : string?,
+ i_rec_end_date : string?,
+ i_item_desc : string?,
+ i_current_price : double?,
+ i_wholesale_cost : double?,
+ i_brand_id : bigint?,
+ i_brand : string?,
+ i_class_id : bigint?,
+ i_class : string?,
+ i_category_id : bigint?,
+ i_category : string?,
+ i_manufact_id : bigint?,
+ i_manufact : string?,
+ i_size : string?,
+ i_formulation : string?,
+ i_color : string?,
+ i_units : string?,
+ i_container : string?,
+ i_manager_id : bigint?,
+ i_product_name : string?
+}
+
+create type tpcds.store_sales_type as
+ closed {
+ ss_sold_date_sk: bigint?,
+ ss_sold_time_sk: bigint?,
+ ss_item_sk: bigint,
+ ss_customer_sk: bigint?,
+ ss_cdemo_sk: bigint?,
+ ss_hdemo_sk: bigint?,
+ ss_addr_sk: bigint?,
+ ss_store_sk: bigint?,
+ ss_promo_sk: bigint?,
+ ss_ticket_number: bigint,
+ ss_quantity: bigint?,
+ ss_wholesale_cost: double?,
+ ss_list_price: double?,
+ ss_sales_price: double?,
+ ss_ext_discount_amt: double?,
+ ss_ext_sales_price: double?,
+ ss_ext_wholesale_cost: double?,
+ ss_ext_list_price: double?,
+ ss_ext_tax: double?,
+ ss_coupon_amt: double?,
+ ss_net_paid: double?,
+ ss_net_paid_inc_tax: double?,
+ ss_net_profit: double?
+}
+
+create type tpcds.date_dim_type as
+ closed {
+ d_date_sk : bigint,
+ d_date_id : string,
+ d_date : string?,
+ d_month_seq : bigint?,
+ d_week_seq : bigint?,
+ d_quarter_seq : bigint?,
+ d_year : bigint? ,
+ d_dow : bigint? ,
+ d_moy : bigint?,
+ d_dom : bigint?,
+ d_qoy : bigint?,
+ d_fy_year : bigint?,
+ d_fy_quarter_seq : bigint?,
+ d_fy_week_seq : bigint?,
+ d_day_name : string?,
+ d_quarter_name : string?,
+ d_holiday : string?,
+ d_weekend : string?,
+ d_following_holiday : string?,
+ d_first_dom : bigint?,
+ d_last_dom : bigint?,
+ d_same_day_ly : bigint?,
+ d_same_day_lq : bigint?,
+ d_current_day : string?,
+ d_current_week : string?,
+ d_current_month : string?,
+ d_current_quarter : string?,
+ d_current_year : string?
+}
+
+create dataset item (item_type) primary key i_item_sk;
+
+create dataset store_sales (store_sales_type) primary key ss_item_sk, ss_ticket_number;
+
+create dataset date_dim(date_dim_type) primary key d_date_sk;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.2.update.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.2.update.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.2.update.sqlpp
new file mode 100644
index 0000000..71629d8
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.2.update.sqlpp
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use tpcds;
+
+
+load dataset item using localfs ((`path`=`asterix_nc1://data/tpcds/item.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset store_sales using localfs ((`path`=`asterix_nc1://data/tpcds/store_sales.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
+
+load dataset date_dim using localfs ((`path`=`asterix_nc1://data/tpcds/date_dim.csv`),(`format`=`delimited-text`),(`delimiter`=`|`));
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.3.query.sqlpp
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.3.query.sqlpp b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.3.query.sqlpp
new file mode 100644
index 0000000..99d81e0
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/tpcds/q98/q98.3.query.sqlpp
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions AND limitations
+ * under the License.
+ */
+
+
+USE tpcds;
+
+SELECT
+ currpricetable.i_item_desc,
+ currpricetable.i_category,
+ currpricetable.i_class,
+ currpricetable.i_current_price,
+ currpricetable.itemrevenue,
+ (currpricetable.itemrevenue * 100 / revrattable.revrat) revenueratio
+FROM
+(SELECT i_item_desc,
+ i_category,
+ i_class,
+ i_current_price,
+ i_item_id,
+ SUM(ss_ext_sales_price) itemrevenue
+FROM
+ store_sales,
+ item,
+ date_dim
+WHERE
+ ss_item_sk = i_item_sk
+ AND i_category IN ["Jewelry", "Sports", "Books"]
+ AND ss_sold_date_sk = d_date_sk
+ AND date(d_date) >= date('2001-01-12')
+ AND date(d_date) <= date('2001-02-11')
+GROUP BY
+ i_item_id,
+ i_item_desc,
+ i_category,
+ i_class,
+ i_current_price
+) AS currpricetable
+JOIN
+(SELECT i_item_id, i_item_desc, i_category, i_class, SUM(ss_ext_sales_price) revrat
+ FROM
+ store_sales,
+ item
+ WHERE ss_item_sk = i_item_sk
+ GROUP BY
+ i_item_id,
+ i_item_desc,
+ i_category,
+ i_class
+) AS revrattable
+ON currpricetable.i_item_id = revrattable.i_item_id
+AND currpricetable.i_class = revrattable.i_class
+AND currpricetable.i_item_desc = revrattable.i_item_desc
+AND currpricetable.i_category = revrattable.i_category
+ORDER BY
+ currpricetable.i_category,
+ currpricetable.i_class,
+ currpricetable.i_item_id,
+ currpricetable.i_item_desc,
+ revenueratio;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q03/q03.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q03/q03.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q03/q03.1.adm
new file mode 100644
index 0000000..31182dc
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q03/q03.1.adm
@@ -0,0 +1 @@
+{ "d_year": 2001, "brand_id": 10008011, "brand": "corpnameless #3", "sum_agg": 4332.24 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q07/q07.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q07/q07.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q07/q07.1.adm
new file mode 100644
index 0000000..cfedddb
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q07/q07.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAACAAAAAAA", "agg1": 630.0, "agg2": 3.83, "agg3": 0.0, "agg4": 1.11 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q15/q15.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q15/q15.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q15/q15.1.adm
new file mode 100644
index 0000000..cdb4592
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q15/q15.1.adm
@@ -0,0 +1 @@
+{ "ca_zip": "35708", "$1": 108.92 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q19/q19.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q19/q19.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q19/q19.1.adm
new file mode 100644
index 0000000..5820ef4
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q19/q19.1.adm
@@ -0,0 +1 @@
+{ "brand_id": 2002002, "brand": "exportiimporto #1", "i_manufact_id": 212, "i_manufact": "barableable", "ext_price": 8484.84 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q21/q21.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q21/q21.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q21/q21.1.adm
new file mode 100644
index 0000000..053af7e
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q21/q21.1.adm
@@ -0,0 +1 @@
+{ "x": { "w_warehouse_name": "Important issues liv", "i_item_id": "AAAAAAAAEAAAAAAA", "inv_before": 200, "inv_after": 300 } }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24a/q24a.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24a/q24a.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24a/q24a.1.adm
new file mode 100644
index 0000000..1d7ade5
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24a/q24a.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Sharp", "c_first_name": "Brunilda", "s_store_name": "anti", "paid": 83.98 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24b/q24b.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24b/q24b.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24b/q24b.1.adm
new file mode 100644
index 0000000..420127b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q24b/q24b.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Sharp", "c_first_name": "Brunilda", "s_store_name": "ought", "paid": 6.68 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q25/q25.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q25/q25.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q25/q25.1.adm
new file mode 100644
index 0000000..c73f5cf
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q25/q25.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAAOAAAAAAA", "i_item_desc": "Teachers carry by the children; old democrats enco", "s_store_id": "AAAAAAAACAAAAAAA", "s_store_name": "ese", "store_sales_profit": -3833.05, "store_returns_loss": 1005.17, "catalog_sales_profit": 5261.55 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q26/q26.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q26/q26.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q26/q26.1.adm
new file mode 100644
index 0000000..7fc4a51
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q26/q26.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAAKAAAAAAA", "agg1": 7.0, "agg2": 40.88, "agg3": 11.56, "agg4": 51.91 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q29/q29.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q29/q29.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q29/q29.1.adm
new file mode 100644
index 0000000..af7a17b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q29/q29.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAAOAAAAAAA", "i_item_desc": "Teachers carry by the children; old democrats enco", "s_store_id": "AAAAAAAACAAAAAAA", "s_store_name": "ese", "store_sales_quantity": 565, "store_returns_quantity": 46, "catalog_sales_quantity": 29 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q30/q30.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q30/q30.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q30/q30.1.adm
new file mode 100644
index 0000000..9833a6b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q30/q30.1.adm
@@ -0,0 +1 @@
+{ "c_customer_id": "AAAAAAAAJAAAAAAA", "c_salutation": "Sir", "c_first_name": "Karl", "c_last_name": "Gilbert", "c_preferred_cust_flag": "N", "c_birth_day": 26, "c_birth_month": 10, "c_birth_year": 1966, "c_birth_country": "MONTSERRAT", "c_login": null, "c_email_address": "Karl.Gilbert@Crg5KyP2IxX9C4d6.edu", "c_last_review_date": "2452454", "ctr_total_return": 100.87 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q31/q31.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q31/q31.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q31/q31.1.adm
new file mode 100644
index 0000000..e8d70a1
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q31/q31.1.adm
@@ -0,0 +1 @@
+{ "ca_county": "Taos County", "d_year": 2000, "web_q1_q2_increase": 1.0, "store_q1_q2_increase": 0.0986730622674497, "web_q2_q3_increase": 0.21626622172784574, "store_q2_q3_increase": 0.0291899504793058 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q34/q34.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q34/q34.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q34/q34.1.adm
new file mode 100644
index 0000000..b59d026
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q34/q34.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Sharp", "c_first_name": "Brunilda", "c_salutation": "Ms.", "c_preferred_cust_flag": "N", "ss_ticket_number": 1, "cnt": 15 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q37/q37.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q37/q37.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q37/q37.1.adm
new file mode 100644
index 0000000..fc3ec07
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q37/q37.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAABAAAAAAA", "i_item_desc": "Powers will not get influences. Electoral ports should show low, annual chains. Now young visitors may pose now however final pages. Bitterly right children suit increasing, leading el", "i_current_price": 27.02 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q41/q41.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q41/q41.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q41/q41.1.adm
new file mode 100644
index 0000000..ae29f2e
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q41/q41.1.adm
@@ -0,0 +1 @@
+{ "i_product_name": "ese" }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q42/q42.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q42/q42.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q42/q42.1.adm
new file mode 100644
index 0000000..a252a02
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q42/q42.1.adm
@@ -0,0 +1,2 @@
+{ "d_year": 1998, "i_category_id": 3, "i_category": "Women", "$1": 85.4 }
+{ "d_year": 1998, "i_category_id": 7, "i_category": "Home", "$1": 33.3 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q43/q43.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q43/q43.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q43/q43.1.adm
new file mode 100644
index 0000000..cd98ef2
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q43/q43.1.adm
@@ -0,0 +1,2 @@
+{ "s_store_name": "able", "s_store_id": "AAAAAAAACAAAAAAA", "sun_sales": null, "mon_sales": null, "tue_sales": 1.11, "wed_sales": null, "thu_sales": null, "fri_sales": null, "sat_sales": null }
+{ "s_store_name": "anti", "s_store_id": "AAAAAAAAEAAAAAAA", "sun_sales": null, "mon_sales": null, "tue_sales": 90.08, "wed_sales": null, "thu_sales": null, "fri_sales": null, "sat_sales": null }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q45/q45.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q45/q45.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q45/q45.1.adm
new file mode 100644
index 0000000..e76b10f
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q45/q45.1.adm
@@ -0,0 +1 @@
+{ "ca_zip": "35709", "ca_county": "Taos County", "$1": 27.43 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q46/q46.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q46/q46.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q46/q46.1.adm
new file mode 100644
index 0000000..356c7dc
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q46/q46.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Lewis", "c_first_name": "Javier", "ca_city": "Fairfield", "bought_city": "Pleasant Valley", "ss_ticket_number": 1, "amt": 0.0, "profit": -302.72 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q50/q50.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q50/q50.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q50/q50.1.adm
new file mode 100644
index 0000000..7b67f68
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q50/q50.1.adm
@@ -0,0 +1,3 @@
+{ "s_store_name": "ese", "s_company_id": 1, "s_street_number": "877", "s_street_name": "Park Laurel", "s_street_type": "Road", "s_suite_number": "Suite T", "s_city": "Midway", "s_county": "Williamson County", "s_state": "TN", "s_zip": "31904", "c30_days": 1, "c31_60_days": 0, "c61_90_days": 0, "c91_120_days": 0, "gt120_days": 0 }
+{ "s_store_name": "ought", "s_company_id": 1, "s_street_number": "767", "s_street_name": "Spring ", "s_street_type": "Wy", "s_suite_number": "Suite 250", "s_city": "Midway", "s_county": "Williamson County", "s_state": "TN", "s_zip": "35709", "c30_days": 1, "c31_60_days": 0, "c61_90_days": 0, "c91_120_days": 0, "gt120_days": 0 }
+
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q52/q52.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q52/q52.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q52/q52.1.adm
new file mode 100644
index 0000000..056a7a8
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q52/q52.1.adm
@@ -0,0 +1,3 @@
+{ "d_year": 1998, "brand_id": 3002001, "brand": "importoexporti #1", "ext_price": 85.4 }
+{ "d_year": 1998, "brand_id": 1001001, "brand": "brandbrand #4", "ext_price": 33.3 }
+
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q55/q55.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q55/q55.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q55/q55.1.adm
new file mode 100644
index 0000000..ba1c91c
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q55/q55.1.adm
@@ -0,0 +1 @@
+{ "brand_id": 10008011, "brand": "corpnameless #3", "ext_price": 4332.24 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q59/q59.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q59/q59.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q59/q59.1.adm
new file mode 100644
index 0000000..c987136
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q59/q59.1.adm
@@ -0,0 +1,2 @@
+{ "s_store_name1": "able", "s_store_id1": "AAAAAAAACAAAAAAA", "d_week_seq1": 1, "$1": null, "$2": null, "$3": null, "$4": null, "$5": null, "$6": null, "$7": null }
+{ "s_store_name1": "ese", "s_store_id1": "AAAAAAAACAAAAAAA", "d_week_seq1": 1, "$1": null, "$2": null, "$3": null, "$4": null, "$5": null, "$6": null, "$7": 2.0351384869780897 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q62/q62.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q62/q62.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q62/q62.1.adm
new file mode 100644
index 0000000..99ff95d
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q62/q62.1.adm
@@ -0,0 +1,2 @@
+{ "$1": null, "sm_type": "LIBRARY", "web_name": "site_0", "c30_days": 1, "c31_60_days": 0, "c61_90_days": 0, "c91_120_days": 0, "gt120_days": 0 }
+{ "$1": "Conventional childr", "sm_type": "NEXT DAY", "web_name": "site_0", "c30_days": 1, "c31_60_days": 0, "c61_90_days": 0, "c91_120_days": 0, "gt120_days": 0 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q68/q68.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q68/q68.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q68/q68.1.adm
new file mode 100644
index 0000000..beec128
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q68/q68.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Sharp", "c_first_name": "Brunilda", "ca_city": "Fairview", "bought_city": "Pleasant Valley", "ss_ticket_number": 1, "extended_price": 4428.0, "extended_tax": 177.12, "list_price": 8051.76 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q73/q73.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q73/q73.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q73/q73.1.adm
new file mode 100644
index 0000000..234ece7
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q73/q73.1.adm
@@ -0,0 +1 @@
+{ "c_last_name": "Sharp", "c_first_name": "Brunilda", "c_salutation": "Ms.", "c_preferred_cust_flag": "N", "ss_ticket_number": 1, "cnt": 4 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q79/q79.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q79/q79.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q79/q79.1.adm
new file mode 100644
index 0000000..74e67ad
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q79/q79.1.adm
@@ -0,0 +1,2 @@
+{ "c_last_name": "Lewis", "c_first_name": "Javier", "$1": "Midway", "ss_ticket_number": 26, "amt": 0.0, "profit": -3833.05 }
+{ "c_last_name": "Wiles", "c_first_name": "Fonda", "$1": "Midway", "ss_ticket_number": 2, "amt": 0.0, "profit": -3833.05 }
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q81/q81.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q81/q81.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q81/q81.1.adm
new file mode 100644
index 0000000..26b0eb2
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q81/q81.1.adm
@@ -0,0 +1 @@
+{ "c_customer_id": "AAAAAAAAIAAAAAAA", "c_salutation": "Sir", "c_first_name": "Ollie", "c_last_name": "Shipman", "ca_street_number": "362", "ca_street_name": "Washington 6th", "ca_street_type": "RD", "ca_suite_number": "Suite 80", "ca_city": "Fairview", "ca_county": "Taos County", "ca_state": "IL", "ca_zip": "35709", "ca_country": "Suriname", "ca_gmt_offset": -7.0, "ca_location_type": "condo", "ctr_total_return": 900.87 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q82/q82.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q82/q82.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q82/q82.1.adm
new file mode 100644
index 0000000..0339d14
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q82/q82.1.adm
@@ -0,0 +1 @@
+{ "i_item_id": "AAAAAAAAHAAAAAAA", "i_item_desc": "Anxious accounts must catch also years. Revolutionary, large directors used to embrace then mo", "i_current_price": 39.94 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q88/q88.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q88/q88.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q88/q88.1.adm
new file mode 100644
index 0000000..8cfbcc0
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q88/q88.1.adm
@@ -0,0 +1 @@
+{ "h8_30_to_9": 0, "h9_to_9_30": 0, "h9_30_to_10": 0, "h10_to_10_30": 1, "h10_30_to_11": 0, "h11_to_11_30": 0, "h11_30_to_12": 0, "h12_to_12_30": 1 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q91/q91.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q91/q91.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q91/q91.1.adm
new file mode 100644
index 0000000..dd582c4
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q91/q91.1.adm
@@ -0,0 +1 @@
+{ "Call_Center": "AAAAAAAACAAAAAAA", "Call_Center_Name": "Mid Atlantic", "Manager": "Felipe Perkins", "Returns_Loss": 106.07 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q94/q94.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q94/q94.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q94/q94.1.adm
new file mode 100644
index 0000000..ed2027f
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q94/q94.1.adm
@@ -0,0 +1 @@
+{ "order_count": 13, "total_shipping_cost": 4813.119999999999, "total_net_profit": 4754.880000000001 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q95/q95.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q95/q95.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q95/q95.1.adm
new file mode 100644
index 0000000..887359c
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q95/q95.1.adm
@@ -0,0 +1 @@
+{ "order_count": 1, "total_shipping_cost": 910.86, "total_net_profit": -129.96 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q96/q96.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q96/q96.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q96/q96.1.adm
new file mode 100644
index 0000000..73a998b
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q96/q96.1.adm
@@ -0,0 +1 @@
+{ "$1": 4 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q98/q98.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q98/q98.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q98/q98.1.adm
new file mode 100644
index 0000000..24d4840
--- /dev/null
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/q98/q98.1.adm
@@ -0,0 +1 @@
+{ "i_item_desc": "Correct, fo", "i_category": "Jewelry", "i_class": "estate", "i_current_price": 54.87, "itemrevenue": 1064.36, "revenueratio": 100.0 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1580/query-ASTERIXDB-1580.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1580/query-ASTERIXDB-1580.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1580/query-ASTERIXDB-1580.1.adm
index 4c6b9f7..aac5eb9 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1580/query-ASTERIXDB-1580.1.adm
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1580/query-ASTERIXDB-1580.1.adm
@@ -1 +1 @@
-{ "state": "MN", "cnt": 10 }
+{ "state": "IL", "cnt": 28 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-2/query-ASTERIXDB-1581-2.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-2/query-ASTERIXDB-1581-2.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-2/query-ASTERIXDB-1581-2.1.adm
index c7a4707..2f7bdfc 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-2/query-ASTERIXDB-1581-2.1.adm
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-2/query-ASTERIXDB-1581-2.1.adm
@@ -1 +1 @@
-{ "bucket1": [ { "$1": 2.16 } ] }
+{ "bucket1": [ { "$1": 24.261666666666667 } ] }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-4/query-ASTERIXDB-1581-4.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-4/query-ASTERIXDB-1581-4.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-4/query-ASTERIXDB-1581-4.1.adm
index 92de03a..ecbf2ce 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-4/query-ASTERIXDB-1581-4.1.adm
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-4/query-ASTERIXDB-1581-4.1.adm
@@ -1 +1 @@
-{ "bucket1": 2.16 }
+{ "bucket1": 24.261666666666667 }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-6/query-ASTERIXDB-1581-6.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-6/query-ASTERIXDB-1581-6.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-6/query-ASTERIXDB-1581-6.1.adm
index 0db3ede..7e6eb68 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-6/query-ASTERIXDB-1581-6.1.adm
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-6/query-ASTERIXDB-1581-6.1.adm
@@ -1 +1 @@
-{ "bucket1": [ { "$2": -377.0216666666667 } ] }
+{ "bucket1": [ { "$2": -746.2933333333334 } ] }
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/36b2c10f/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-correlated/query-ASTERIXDB-1581-correlated.1.adm
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-correlated/query-ASTERIXDB-1581-correlated.1.adm b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-correlated/query-ASTERIXDB-1581-correlated.1.adm
index aad62bb..d9395d8 100644
--- a/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-correlated/query-ASTERIXDB-1581-correlated.1.adm
+++ b/asterixdb/asterix-app/src/test/resources/runtimets/results/tpcds/query-ASTERIXDB-1581-correlated/query-ASTERIXDB-1581-correlated.1.adm
@@ -1 +1 @@
-{ "bucket1": [ { "$1": 0.0 } ] }
+{ "bucket1": [ { "$1": 46.03 } ] }
\ No newline at end of file