Function mz_compute::render::reduce::build_basic_aggregate

fn build_basic_aggregate<G>(
    debug_name: &str,
    input: Collection<G, (Row, Row), Diff>,
    index: usize,
    aggr: &AggregateExpr,
    validating: bool
) -> (Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>, Option<Collection<G, DataflowError, Diff>>)where
    G: Scope,
    G::Timestamp: Lattice,

Build the dataflow to compute a single basic aggregation.

This method also applies distinctness if required.