collect_batches

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.