risingwave_batch::task::consistent_hash_shuffle_channel

Function new_consistent_shuffle_channel

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