Function deltalake::datafusion::physical_plan::common::collect

source · 
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