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