pub(crate) fn split_record_batch( record_batch: RecordBatch, batches: &mut VecDeque<RecordBatch>, )
Splits the batch so each sub-batch has strictly increasing timestamps.
Panics if the timestamp array is invalid.