flow::compute::render::reduce

Function batch_split_by_key_val

Source 
fn batch_split_by_key_val(
    batch: &Batch,
    key_val_plan: &KeyValPlan,
    err_collector: &ErrCollector,
) -> (Batch, Batch)