common_recordbatch::util

Function collect_batches

source 
pub async fn collect_batches(
    stream: SendableRecordBatchStream,
) -> Result<RecordBatches>
Expand description

Collect all the items from the stream into RecordBatches.