Make aggregates::group_values module public for use in dedup operator

coralogix · Sep 18, 2024 · b5d119b · b5d119b
1 parent f490e9e
commit b5d119b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datafusion/physical-plan/src/aggregates/mod.rs b/datafusion/physical-plan/src/aggregates/mod.rs
@@ -48,7 +48,7 @@ use datafusion_physical_expr::{
 
 use itertools::Itertools;
 
-mod group_values;
+pub mod group_values;
 mod no_grouping;
 mod order;
 mod row_hash;
@@ -822,7 +822,7 @@ fn create_schema(
     Ok(Schema::new(fields))
 }
 
-fn group_schema(schema: &Schema, group_count: usize) -> SchemaRef {
+pub fn group_schema(schema: &Schema, group_count: usize) -> SchemaRef {
     let group_fields = schema.fields()[0..group_count].to_vec();
     Arc::new(Schema::new(group_fields))
 }