pub fn bounded_stream(
batch: RecordBatch,
limit: usize,
) -> SendableRecordBatchStream
Expand description
Creates an bounded stream for testing purposes.
pub fn bounded_stream(
batch: RecordBatch,
limit: usize,
) -> SendableRecordBatchStream
Creates an bounded stream for testing purposes.