Struct DynamicPartitionPruningRule 

pub struct DynamicPartitionPruningRule { /* private fields */ }

AQE rule that injects a runtime filter on the probe side of a star-schema join, sourced from the build side’s distinct values.

Implementations

impl DynamicPartitionPruningRule

pub fn new(max_build_rows: u64, max_keys: usize) -> Self

Create a DPP rule with the given build-row cap and key cap.

pub fn with_defaults() -> Self

Create a DPP rule with the production-default caps.

Trait Implementations

impl AqeRule for DynamicPartitionPruningRule

fn name(&self) -> &str

Short, stable rule name used in explain and diagnostics output.

fn apply( &self, plan: &PhysicalPlan, stats: &[RuntimeStats], ) -> Option<PhysicalPlan>

Apply the AQE rule given collected RuntimeStats for each stage.