Function mz_timely_util::operator::consolidate_pact

pub fn consolidate_pact<B, P, G, K, V, R>(
    collection: &Collection<G, (K, V), R>,
    pact: P,
    name: &str,
) -> Collection<G, (K, V), R>
where
    G: Scope,
    K: Data,
    V: Data,
    R: Data + Semigroup,
    B: Batcher<Input = Vec<((K, V), G::Timestamp, R)>, Time = G::Timestamp> + 'static,
    B::Output: Container,
    for<'a> Vec<((K, V), G::Timestamp, R)>: PushInto<<B::Output as Container>::Item<'a>>,
    P: ParallelizationContract<G::Timestamp, Vec<((K, V), G::Timestamp, R)>>,

Aggregates the weights of equal records into at most one record.

The data are accumulated in place, each held back until their timestamp has completed.

This serves as a low-level building-block for more user-friendly functions.