diff --git a/spark/src/test/resources/tpcds-micro-benchmarks/agg_sum_integers_with_grouping.sql b/spark/src/test/resources/tpcds-micro-benchmarks/agg_sum_integers_with_grouping.sql new file mode 100644 index 0000000000..c65c536fd6 --- /dev/null +++ b/spark/src/test/resources/tpcds-micro-benchmarks/agg_sum_integers_with_grouping.sql @@ -0,0 +1,32 @@ +-- 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. + +select + ss_quantity, + sum(ss_sold_date_sk), + sum(ss_sold_time_sk), + sum(ss_item_sk), + sum(ss_customer_sk), + sum(ss_cdemo_sk), + sum(ss_hdemo_sk), + sum(ss_addr_sk), + sum(ss_store_sk), + sum(ss_promo_sk), + sum(ss_ticket_number), + sum(ss_quantity) +from store_sales +group by ss_quantity; \ No newline at end of file diff --git a/spark/src/test/scala/org/apache/spark/sql/benchmark/CometTPCDSMicroBenchmark.scala b/spark/src/test/scala/org/apache/spark/sql/benchmark/CometTPCDSMicroBenchmark.scala index 3207daa211..a672d0937d 100644 --- a/spark/src/test/scala/org/apache/spark/sql/benchmark/CometTPCDSMicroBenchmark.scala +++ b/spark/src/test/scala/org/apache/spark/sql/benchmark/CometTPCDSMicroBenchmark.scala @@ -61,6 +61,7 @@ object CometTPCDSMicroBenchmark extends CometTPCQueryBenchmarkBase { "agg_low_cardinality", "agg_sum_decimals_no_grouping", "agg_sum_integers_no_grouping", + "agg_sum_integers_with_grouping", "agg_stddev", "case_when_column_or_null", "case_when_scalar",