pub async fn collect_sendable_stream(
stream: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>,
) -> Result<Vec<RecordBatch>, DataFusionError>
Expand description
Create a vector of record batches from a stream
pub async fn collect_sendable_stream(
stream: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>,
) -> Result<Vec<RecordBatch>, DataFusionError>
Create a vector of record batches from a stream