Struct OptimizationInvariantChecker 

struct OptimizationInvariantChecker<'a> {
    rule: &'a Arc<dyn PhysicalOptimizerRule + Send + Sync>,
}

Fields

rule: &'a Arc<dyn PhysicalOptimizerRule + Send + Sync>

Implementations

impl<'a> OptimizationInvariantChecker<'a>

pub fn new(rule: &'a Arc<dyn PhysicalOptimizerRule + Send + Sync>) -> Self

Create an OptimizationInvariantChecker that performs checking per tule.

pub fn check( &mut self, plan: &Arc<dyn ExecutionPlan>, previous_schema: Arc<Schema>, ) -> Result<()>

Checks that the plan change is permitted, returning an Error if not.

Conditionally performs schema checks per PhysicalOptimizerRule::schema_check. In debug mode, this recursively walks the entire physical plan and performs ExecutionPlan::check_invariants.

Trait Implementations

impl<'n> TreeNodeVisitor<'n> for OptimizationInvariantChecker<'_>

type Node = Arc<dyn ExecutionPlan>

The node type which is visitable.

fn f_down(&mut self, node: &'n Self::Node) -> Result<TreeNodeRecursion>

Invoked while traversing down the tree, before any children are visited. Default implementation continues the recursion.

fn f_up( &mut self, _node: &'n Self::Node, ) -> Result<TreeNodeRecursion, DataFusionError>

Invoked while traversing up the tree after children are visited. Default implementation continues the recursion.