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.