pub async fn collect(stream: SendableRecordBatchStream) -> Result<Vec<RecordBatch>> {
    stream
        .try_collect::<Vec<_>>()
        .await
        .map_err(DataFusionError::from)
}
/// Create a vector of record batches from a stream
Create a vector of record batches from a stream
Create a vector of record batches from a stream
pub async fn collect(stream: SendableRecordBatchStream) -> Result<Vec<RecordBatch>> {
    stream
        .try_collect::<Vec<_>>()
        .await
        .map_err(DataFusionError::from)
}
pub async fn collect ( stream : SendableRecordBatchStream ) -> Result < Vec < RecordBatch > > { stream . try_collect :: < Vec < _ > > ( ) . await . map_err ( DataFusionError :: from ) }
Create a vector of record batches from a stream
Create a vector of record batches from a stream
stream
SendableRecordBatchStream
stream
SendableRecordBatchStream