Function mz_timely_util::operator::consolidate_pact

source · 
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)>, Output = ((K, V), G::Timestamp, R), Time = G::Timestamp> + 'static,
    P: ParallelizationContract<G::Timestamp, Vec<((K, V), G::Timestamp, R)>>,
Expand description

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.