Struct datafusion::physical_plan::repartition::RepartitionExec

pub struct RepartitionExec { /* fields omitted */ }

The repartition operator maps N input partitions to M output partitions based on a partitioning scheme. No guarantees are made about the order of the resulting partitions.

Implementations

impl RepartitionExec

pub fn input(&self) -> &Arc<dyn ExecutionPlan>

Input execution plan

pub fn partitioning(&self) -> &Partitioning

Partitioning scheme to use

impl RepartitionExec

pub fn try_new(
    input: Arc<dyn ExecutionPlan>,
    partitioning: Partitioning
) -> Result<Self>

Create a new RepartitionExec

Trait Implementations

impl Debug for RepartitionExec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ExecutionPlan for RepartitionExec

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>

Get a list of child execution plans that provide the input for this plan. The returned list will be empty for leaf nodes, will contain a single value for unary nodes, or two values for binary nodes (such as joins).

fn with_new_children(
    &self,
    children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>

Returns a new plan where all children were replaced by new plans. The size of children must be equal to the size of ExecutionPlan::children().

fn output_partitioning(&self) -> Partitioning

Specifies the output partitioning scheme of this plan

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, 

creates an iterator

fn required_child_distribution(&self) -> Distribution

Specifies the data distribution requirements of all the children for this operator