Struct deltalake::datafusion::physical_optimizer::enforce_sorting::EnforceSorting

pub struct EnforceSorting {}

This rule inspects SortExec’s in the given physical plan and removes the ones it can prove unnecessary.

Implementations

impl EnforceSorting

pub fn new() -> EnforceSorting

Trait Implementations

impl Default for EnforceSorting

fn default() -> EnforceSorting

Returns the “default value” for a type.

impl PhysicalOptimizerRule for EnforceSorting

The boolean flag repartition_sorts defined in the config indicates whether we elect to transform CoalescePartitionsExec + SortExec cascades into SortExec + SortPreservingMergeExec cascades, which enables us to perform sorting in parallel.

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

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 valid 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.