flow::compute::render::reduce

Function eval_distinct_aggrs

Source 
fn eval_distinct_aggrs(
    distinct_aggrs: &Vec<AggrWithIndex>,
    distinct_input: &Option<Vec<ArrangeHandler>>,
    accums: &[Value],
    accum_ranges: &[Range<usize>],
    col_diffs: &[Vec<(Value, i64)>],
    accum_output: &mut AccumOutput,
    _: SubgraphArg<'_>,
)
Expand description

Eval distinct aggregate functions with distinct input arrange