Function mz_timely_util::operator::consolidate_pact

source ยท 
pub fn consolidate_pact<B, P, G, CI, CO>(
    stream: &StreamCore<G, CI>,
    pact: P,
    name: &str,
) -> StreamCore<G, CO>
where
    G: Scope,
    B: Batcher<Input = CI, Time = G::Timestamp> + 'static,
    B::Output: Container,
    for<'a> CO: PushInto<<B::Output as Container>::Item<'a>> + SizableContainer + Data,
    P: ParallelizationContract<G::Timestamp, CI>,
    CI: Container + Data,
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.