Struct datafusion::physical_plan::planner::DefaultPhysicalPlanner

pub struct DefaultPhysicalPlanner { /* fields omitted */ }

Default single node physical query planner that converts a LogicalPlan to an ExecutionPlan suitable for execution.

Implementations

impl DefaultPhysicalPlanner

pub fn with_extension_planner(
    extension_planner: Arc<dyn ExtensionPlanner + Send + Sync>
) -> Self

Create a physical planner that uses extension_planner to plan extension nodes.

pub fn create_physical_expr(
    &self,
    e: &Expr,
    input_schema: &Schema,
    ctx_state: &ExecutionContextState
) -> Result<Arc<dyn PhysicalExpr>>

Create a physical expression from a logical expression

pub fn create_aggregate_expr(
    &self,
    e: &Expr,
    input_schema: &Schema,
    ctx_state: &ExecutionContextState
) -> Result<Arc<dyn AggregateExpr>>

Create an aggregate expression from a logical expression

pub fn create_physical_sort_expr(
    &self,
    e: &Expr,
    input_schema: &Schema,
    options: SortOptions,
    ctx_state: &ExecutionContextState
) -> Result<PhysicalSortExpr>

Create an aggregate expression from a logical expression

Trait Implementations

impl Default for DefaultPhysicalPlanner

fn default() -> Self

Create an implementation of the default physical planner

impl PhysicalPlanner for DefaultPhysicalPlanner

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

Create a physical plan from a logical plan