Function mz_compute::render::reduce::build_accumulable

fn build_accumulable<G>(
    debug_name: &str,
    collection: Collection<G, (Row, Row), Diff>,
    _: AccumulablePlan
) -> (Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>, Collection<G, DataflowError, Diff>)where
    G: Scope,
    G::Timestamp: Lattice,

Build the dataflow to compute and arrange multiple accumulable aggregations.

The incoming values are moved to the update’s “difference” field, at which point they can be accumulated in place. The count operator promotes the accumulated values to data, at which point a final map applies operator-specific logic to yield the final aggregate.