flow::compute::render::reduce

Function split_rows_to_key_val

Source 
fn split_rows_to_key_val(
    rows: impl IntoIterator<Item = (Row, i64, i64)>,
    key_val_plan: KeyValPlan,
    err_collector: ErrCollector,
) -> impl IntoIterator<Item = ((Row, Row), i64, i64)>
Expand description

split a row into key and val by evaluate the key and val plan