Skip to main content

record_batch_channel

Function record_batch_channel 

Source
pub fn record_batch_channel(
    capacity: usize,
) -> (RecordBatchSender, RecordBatchReceiver)
Expand description

Creates a bounded input channel for streaming SQL queries.

A bounded channel applies backpressure to producers; capacity zero creates a rendezvous channel.