refactor count_distinct to not to have update and merge

apache · Feb 28, 2023 · 2517567 · 2517567
1 parent 8b92b9b
commit 2517567
Show file tree

Hide file tree

Showing 2 changed files with 115 additions and 296 deletions.
diff --git a/datafusion/physical-expr/src/aggregate/build_in.rs b/datafusion/physical-expr/src/aggregate/build_in.rs
@@ -58,10 +58,9 @@ pub fn create_aggregate_expr(
             return_type,
         )),
         (AggregateFunction::Count, true) => Arc::new(expressions::DistinctCount::new(
-            input_phy_types,
-            input_phy_exprs,
+            input_phy_types[0].clone(),
+            input_phy_exprs[0].clone(),
             name,
-            return_type,
         )),
         (AggregateFunction::Grouping, _) => Arc::new(expressions::Grouping::new(
             input_phy_exprs[0].clone(),