Function dataflow::render::reduce::build_basic_aggregate[][src]

fn build_basic_aggregate<G>(
    input: Collection<G, (Row, Row)>,
    index: usize,
    aggr: &AggregateExpr
) -> Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>> where
    G: Scope,
    G::Timestamp: Lattice
Expand description

Build the dataflow to compute a single basic aggregation.

This method also applies distinctness if required.