lance_datafusion::chunker

Function chunk_concat_stream

Source
pub fn chunk_concat_stream(
    stream: SendableRecordBatchStream,
    chunk_size: usize,
) -> SendableRecordBatchStream