pub async fn collect(
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(
stream: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>,
) -> Result<Vec<RecordBatch>, DataFusionError>Create a vector of record batches from a stream