pub struct DefaultPhysicalPlanner { /* private fields */ }
Expand description
Default single node physical query planner that converts a
LogicalPlan
to an ExecutionPlan
suitable for execution.
Implementations§
source§impl DefaultPhysicalPlanner
impl DefaultPhysicalPlanner
sourcepub fn with_extension_planners(
extension_planners: Vec<Arc<dyn ExtensionPlanner + Send + Sync>>
) -> Self
pub fn with_extension_planners( extension_planners: Vec<Arc<dyn ExtensionPlanner + Send + Sync>> ) -> Self
Create a physical planner that uses extension_planners
to
plan user-defined logical nodes LogicalPlan::Extension
.
The planner uses the first ExtensionPlanner
to return a non-None
plan.
Trait Implementations§
source§impl Default for DefaultPhysicalPlanner
impl Default for DefaultPhysicalPlanner
source§fn default() -> DefaultPhysicalPlanner
fn default() -> DefaultPhysicalPlanner
Returns the “default value” for a type. Read more
source§impl PhysicalPlanner for DefaultPhysicalPlanner
impl PhysicalPlanner for DefaultPhysicalPlanner
source§fn create_physical_plan<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
logical_plan: &'life1 LogicalPlan,
session_state: &'life2 SessionState
) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn create_physical_plan<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, logical_plan: &'life1 LogicalPlan, session_state: &'life2 SessionState ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn ExecutionPlan>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,
Create a physical plan from a logical plan
source§fn create_physical_expr(
&self,
expr: &Expr,
input_dfschema: &DFSchema,
input_schema: &Schema,
session_state: &SessionState
) -> Result<Arc<dyn PhysicalExpr>>
fn create_physical_expr( &self, expr: &Expr, input_dfschema: &DFSchema, input_schema: &Schema, session_state: &SessionState ) -> Result<Arc<dyn PhysicalExpr>>
Create a physical expression from a logical expression suitable for evaluation
e
: the expression to convert
input_dfschema
: the logical plan schema for evaluating e
input_schema
: the physical schema for evaluating e
Auto Trait Implementations§
impl !RefUnwindSafe for DefaultPhysicalPlanner
impl Send for DefaultPhysicalPlanner
impl Sync for DefaultPhysicalPlanner
impl Unpin for DefaultPhysicalPlanner
impl !UnwindSafe for DefaultPhysicalPlanner
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more