Skip to content

Commit 724e220

Browse files
re-publicise functions DQE relies on
1 parent 2cb84e6 commit 724e220

File tree

2 files changed

+3
-3
lines changed
  • datafusion/physical-plan/src/aggregates

2 files changed

+3
-3
lines changed

datafusion/physical-plan/src/aggregates/group_values/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ mod null_builder;
8686
/// Each distinct group in a hash aggregation is identified by a unique group id
8787
/// (usize) which is assigned by instances of this trait. Group ids are
8888
/// continuous without gaps, starting from 0.
89-
pub(crate) trait GroupValues: Send {
89+
pub trait GroupValues: Send {
9090
/// Calculates the group id for each input row of `cols`, assigning new
9191
/// group ids as necessary.
9292
///
@@ -129,7 +129,7 @@ pub(crate) trait GroupValues: Send {
129129
///
130130
/// [`GroupColumn`]: crate::aggregates::group_values::multi_group_by::GroupColumn
131131
///
132-
pub(crate) fn new_group_values(
132+
pub fn new_group_values(
133133
schema: SchemaRef,
134134
group_ordering: &GroupOrdering,
135135
) -> Result<Box<dyn GroupValues>> {

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ use datafusion_physical_expr::{
5252

5353
use itertools::Itertools;
5454

55-
pub(crate) mod group_values;
55+
pub mod group_values;
5656
mod no_grouping;
5757
pub mod order;
5858
mod row_hash;

0 commit comments

Comments
 (0)