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.