Function lance_datafusion::chunker::chunk_stream

source · 
pub fn chunk_stream(
    stream: SendableRecordBatchStream,
    chunk_size: usize
) -> Pin<Box<dyn Stream<Item = Result<Vec<RecordBatch>>> + Send>>