risingwave_batch::task::channel

Function create_output_channel

source
pub fn create_output_channel(
    shuffle: &ExchangeInfo,
    output_channel_size: usize,
) -> Result<(ChanSenderImpl, Vec<ChanReceiverImpl>)>
Expand description

Output-channel is a synchronous, bounded single-producer-multiple-consumer queue. The producer is the local task executor, the consumer is ExchangeService. The implementation depends on the shuffling strategy.