pub async fn collect(
stream: SendableRecordBatchStream,
) -> Result<Vec<RecordBatch>>
Expand description
Collect all the items from the stream into a vector of RecordBatch
.
pub async fn collect(
stream: SendableRecordBatchStream,
) -> Result<Vec<RecordBatch>>
Collect all the items from the stream into a vector of RecordBatch
.