query::window_sort

Function get_sorted_runs

Source
fn get_sorted_runs(sort_column: SortColumn) -> Result<Vec<SucRun<Timestamp>>>
Expand description

return a list of non-overlapping (offset, length) which represent sorted runs, and can be used to call [DfRecordBatch::slice] to get sorted runs Returned runs will be as long as possible, and will not overlap with each other