Trait datafusion::execution::context::QueryPlanner

pub trait QueryPlanner {
    fn create_physical_plan(
        &self, 
        logical_plan: &LogicalPlan, 
        ctx_state: &ExecutionContextState
    ) -> Result<Arc<dyn ExecutionPlan>>;

    fn rewrite_logical_plan(&self, plan: LogicalPlan) -> Result<LogicalPlan> { ... }
}

A planner used to add extensions to DataFusion logical and phusical plans.

Required methods

fn create_physical_plan(
    &self,
    logical_plan: &LogicalPlan,
    ctx_state: &ExecutionContextState
) -> Result<Arc<dyn ExecutionPlan>>

Given a LogicalPlan, create an ExecutionPlan suitable for execution

Loading content...

Provided methods

fn rewrite_logical_plan(&self, plan: LogicalPlan) -> Result<LogicalPlan>

Given a LogicalPlan, create a new, modified LogicalPlan plan. This method is run after built in OptimizerRules. By default returns the plan unmodified.

Loading content...

Implementors

Loading content...