Function mz_timely_util::reclock::reclock

source · 
pub fn reclock<G, D, FromTime, IntoTime, R>(
    remap_collection: &Collection<G, FromTime, i64>,
    as_of: Antichain<G::Timestamp>,
) -> (Box<dyn Push<Message<Event<FromTime, Vec<(D, FromTime, R)>>>>>, Collection<G, D, R>)
where
    G: Scope<Timestamp = IntoTime>,
    D: ExchangeData,
    FromTime: Timestamp,
    IntoTime: Timestamp + Lattice + TotalOrder,
    R: Semigroup + 'static,
Expand description

Constructs an operator that reclocks a source collection varying with some time FromTime into the corresponding reclocked collection varying over some time IntoTime using the provided remap collection.

In order for the operator to read the source collection a Pusher is returned which can be used with timely’s capture facilities to connect a collection from a foreign scope to this operator.