deltalake_core::operations

Function collect_sendable_stream

Source
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