Skip to content

Commit 133fd85

Browse files
committed
Add built-in operator statistics providers
Adds chain-of-responsibility providers for common physical operators: - FilterStatisticsProvider: selectivity-based output estimation using pre-enhanced child statistics, with post-filter NDV adjustment - ProjectionStatisticsProvider: passthrough with column mapping - PassthroughStatisticsProvider: cardinality-preserving operators (Sort, Repartition, Window, etc.) via CardinalityEffect - AggregateStatisticsProvider: NDV-product estimation for GROUP BY, delegates for Partial mode and multiple grouping sets (apache#20926)
1 parent ff3f8f8 commit 133fd85

File tree

2 files changed

+1140
-43
lines changed

2 files changed

+1140
-43
lines changed

datafusion/physical-plan/src/filter.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,7 @@ impl FilterExec {
309309
}
310310

311311
/// Calculates `Statistics` for `FilterExec`, by applying selectivity (either default, or estimated) to input statistics.
312-
fn statistics_helper(
312+
pub(crate) fn statistics_helper(
313313
schema: &SchemaRef,
314314
input_stats: Statistics,
315315
predicate: &Arc<dyn PhysicalExpr>,

0 commit comments

Comments
 (0)