From c0bd21c2ec568380e41ec006630e8ae0d9587436 Mon Sep 17 00:00:00 2001 From: vlyubin Date: Tue, 16 May 2017 10:29:00 +0200 Subject: [PATCH] Add ss_max --- src/main/resources/tpcds_2_4/ss_max.sql | 14 ++++++++++++++ .../spark/sql/perf/tpcds/TPCDS_2_4_Queries.scala | 3 ++- 2 files changed, 16 insertions(+), 1 deletion(-) create mode 100644 src/main/resources/tpcds_2_4/ss_max.sql diff --git a/src/main/resources/tpcds_2_4/ss_max.sql b/src/main/resources/tpcds_2_4/ss_max.sql new file mode 100644 index 0000000..1c0a57f --- /dev/null +++ b/src/main/resources/tpcds_2_4/ss_max.sql @@ -0,0 +1,14 @@ +select + count(*) as total, + count(ss_sold_date_sk) as not_null_total, + count(distinct ss_sold_date_sk) as unique_days, + max(ss_sold_date_sk) as max_ss_sold_date_sk, + max(ss_sold_time_sk) as max_ss_sold_time_sk, + max(ss_item_sk) as max_ss_item_sk, + max(ss_customer_sk) as max_ss_customer_sk, + max(ss_cdemo_sk) as max_ss_cdemo_sk, + max(ss_hdemo_sk) as max_ss_hdemo_sk, + max(ss_addr_sk) as max_ss_addr_sk, + max(ss_store_sk) as max_ss_store_sk, + max(ss_promo_sk) as max_ss_promo_sk +from store_sales diff --git a/src/main/scala/com/databricks/spark/sql/perf/tpcds/TPCDS_2_4_Queries.scala b/src/main/scala/com/databricks/spark/sql/perf/tpcds/TPCDS_2_4_Queries.scala index bba2520..f08e3b2 100644 --- a/src/main/scala/com/databricks/spark/sql/perf/tpcds/TPCDS_2_4_Queries.scala +++ b/src/main/scala/com/databricks/spark/sql/perf/tpcds/TPCDS_2_4_Queries.scala @@ -37,7 +37,8 @@ trait Tpcds_2_4_Queries extends Benchmark { "q59", "q60", "q61", "q62", "q63", "q64", "q65", "q66", "q67", "q68", "q69", "q70", "q71", "q72", "q73", "q74", "q75", "q76", "q77", "q78", "q79", "q80", "q81", "q82", "q83", "q84", "q85", "q86", "q87", "q88", "q89", - "q90", "q91", "q92", "q93", "q94", "q95", "q96", "q97", "q98", "q99" + "q90", "q91", "q92", "q93", "q94", "q95", "q96", "q97", "q98", "q99", + "ss_max" ) val tpcds2_4Queries = queryNames.map { queryName =>