risingwave_batch::task::hash_shuffle_channel

Function new_hash_shuffle_channel

Source 
pub fn new_hash_shuffle_channel(
    shuffle: &ExchangeInfo,
    output_channel_size: usize,
) -> (ChanSenderImpl, Vec<ChanReceiverImpl>)