add_roundrobin_on_top

datafusion_physical_optimizer::enforce_distribution

Function add_roundrobin_on_top 

Source 
fn add_roundrobin_on_top(
    input: DistributionContext,
    n_target: usize,
) -> Result<DistributionContext>
Expand description

Adds RoundRobin repartition operator to the plan increase parallelism.

§Arguments

  • input: Current node.
  • n_target: desired target partition number, if partition number of the current executor is less than this value. Partition number will be increased.

§Returns

A Result object that contains new execution plan where the desired partition number is achieved by adding a RoundRobin repartition.