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