risingwave_batch::task::broadcast_channel

Function new_broadcast_channel

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