Struct datafusion::physical_plan::projection::ProjectionExec [−][src]
pub struct ProjectionExec { /* fields omitted */ }
Execution plan for a projection
Implementations
impl ProjectionExec
[src]
impl ProjectionExec
[src]pub fn try_new(
expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
[src]
expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
Create a projection on an input
pub fn expr(&self) -> &[(Arc<dyn PhysicalExpr>, String)]
[src]
The projection expressions stored as tuples of (expression, output column name)
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
The input plan
Trait Implementations
impl ExecutionPlan for ProjectionExec
[src]
impl ExecutionPlan for ProjectionExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
Get the schema for this execution plan
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
fn with_new_children(
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
fn execute<'life0, 'async_trait>(
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn required_child_distribution(&self) -> Distribution
[src]
fn metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for ProjectionExec
impl !RefUnwindSafe for ProjectionExec
impl Send for ProjectionExec
impl Send for ProjectionExec
impl Sync for ProjectionExec
impl Sync for ProjectionExec
impl Unpin for ProjectionExec
impl Unpin for ProjectionExec
impl !UnwindSafe for ProjectionExec
impl !UnwindSafe for ProjectionExec