split_record_batch

Function split_record_batch 

Source
pub(crate) fn split_record_batch(
    record_batch: RecordBatch,
    batches: &mut VecDeque<RecordBatch>,
)
Expand description

Splits the batch by timestamps.

ยงPanics

Panics if the timestamp array is invalid.