partition_aware_channels

datafusion_physical_plan::repartition::distributor_channels

Function partition_aware_channels 

Source 
pub fn partition_aware_channels<T>(
    n_in: usize,
    n_out: usize,
) -> (Vec<Vec<DistributionSender<T>>>, Vec<Vec<DistributionReceiver<T>>>)
Expand description

Create n_out empty channels for each of the n_in inputs. This way, each distinct partition will communicate via a dedicated channel. This SPSC structure enables us to track which partition input data comes from.