flow::compute::render::reduce

Function update_reduce_distinct_arrange

Source 
fn update_reduce_distinct_arrange(
    arrange: &ArrangeHandler,
    kv: impl IntoIterator<Item = ((Row, Row), i64, i64)>,
    now: i64,
    err_collector: &ErrCollector,
) -> impl Iterator<Item = (Row, i64, i64)>
Expand description

eval distinct reduce plan, output the distinct, and update the arrangement

This function is extracted because also want to use it to update distinct input of accumulable reduce plan