Struct EnsureRequirements 

pub struct EnsureRequirements {}

Optimizer rule that enforces both distribution and sorting requirements.

This rule combines the functionality of EnforceDistribution and EnforceSorting into a coordinated sequence where distribution is always settled before sorting for each operator, preventing the non-idempotent interactions between the two separate rules.

See module level documentation for more details.

Implementations

impl EnsureRequirements

pub fn new() -> Self

Create a new EnsureRequirements optimizer rule.

Trait Implementations

impl Debug for EnsureRequirements

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for EnsureRequirements

fn default() -> EnsureRequirements

Returns the “default value” for a type.

impl PhysicalOptimizerRule for EnsureRequirements

fn optimize( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, ) -> Result<Arc<dyn ExecutionPlan>>

Rewrite plan to an optimized form.

fn name(&self) -> &str

A human readable name for this optimizer rule

fn schema_check(&self) -> bool

A flag to indicate whether the physical planner should validate that the rule will not change the schema of the plan after the rewriting. Some of the optimization rules might change the nullable properties of the schema and should disable the schema check.

fn optimize_with_context( &self, plan: Arc<dyn ExecutionPlan>, context: &dyn PhysicalOptimizerContext, ) -> Result<Arc<dyn ExecutionPlan>, DataFusionError>

Rewrite plan with access to extended context (statistics registry, etc.).