Struct datafusion::physical_plan::merge::MergeExec [−][src]
pub struct MergeExec { /* fields omitted */ }
Merge execution plan executes partitions in parallel and combines them into a single partition. No guarantees are made about the order of the resulting partition.
Implementations
impl MergeExec
[src]
impl MergeExec
[src]pub fn new(input: Arc<dyn ExecutionPlan>) -> Self
[src]
Create a new MergeExec
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
Input execution plan
Trait Implementations
impl ExecutionPlan for MergeExec
[src]
impl ExecutionPlan for MergeExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
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 MergeExec
impl !RefUnwindSafe for MergeExec
impl !UnwindSafe for MergeExec
impl !UnwindSafe for MergeExec