Skip to content

Commit 1c65b6a

Browse files
Update count optimization function names
1 parent 42c01d1 commit 1c65b6a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

datafusion/src/physical_optimizer/aggregate_statistics.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,11 +58,11 @@ impl PhysicalOptimizerRule for AggregateStatistics {
5858
let mut projections = vec![];
5959
for expr in partial_agg_exec.aggr_expr() {
6060
if let Some((non_null_rows, name)) =
61-
take_optimizable_count_with_nulls(&**expr, &stats)
61+
take_optimizable_column_count(&**expr, &stats)
6262
{
6363
projections.push((expressions::lit(non_null_rows), name.to_owned()));
6464
} else if let Some((num_rows, name)) =
65-
take_optimizable_count(&**expr, &stats)
65+
take_optimizable_table_count(&**expr, &stats)
6666
{
6767
projections.push((expressions::lit(num_rows), name.to_owned()));
6868
} else if let Some((min, name)) = take_optimizable_min(&**expr, &stats) {
@@ -133,7 +133,7 @@ fn take_optimizable(node: &dyn ExecutionPlan) -> Option<Arc<dyn ExecutionPlan>>
133133
}
134134

135135
/// If this agg_expr is a count that is defined in the statistics, return it
136-
fn take_optimizable_count(
136+
fn take_optimizable_table_count(
137137
agg_expr: &dyn AggregateExpr,
138138
stats: &Statistics,
139139
) -> Option<(ScalarValue, &'static str)> {
@@ -160,7 +160,7 @@ fn take_optimizable_count(
160160
}
161161

162162
/// If this agg_expr is a count that can be derived from the statistics, return it
163-
fn take_optimizable_count_with_nulls(
163+
fn take_optimizable_column_count(
164164
agg_expr: &dyn AggregateExpr,
165165
stats: &Statistics,
166166
) -> Option<(ScalarValue, String)> {

0 commit comments

Comments
 (0)