add tpch test

Author: goldmedal

datafusion/physical-plan/src/aggregates/row_hash.rs

@@ -699,6 +699,7 @@ impl Stream for GroupedHashAggregateStream {
                             let timer = elapsed_compute.timer();
 
                             let batch = self.filter_by_selection_vector(batch)?;
+
                             // Make sure we have enough capacity for `batch`, otherwise spill
                             self.spill_previous_if_necessary(&batch)?;
 

datafusion/sqllogictest/test_files/tpch/tpch.slt

@@ -21,6 +21,21 @@ include ./create_tables.slt.part
 include ./plans/q*.slt.part
 include ./answers/q*.slt.part
 
+# test hash join with selection vector
+statement ok
+set datafusion.optimizer.prefer_hash_selection_vector_partitioning_agg = true;
+
+statement ok
+set datafusion.optimizer.hash_join_single_partition_threshold = 0;
+
+include ./answers/q*.slt.part
+
+statement ok
+set datafusion.optimizer.prefer_hash_selection_vector_partitioning_agg = false;
+
+statement ok
+set datafusion.optimizer.hash_join_single_partition_threshold = 1048576;
+
 # test answers with sort merge join
 statement ok
 set datafusion.optimizer.prefer_hash_join = false;