pub fn reclock<G, D, FromTime, IntoTime, R>(
remap_collection: &Collection<G, FromTime, Overflowing<i64>>,
as_of: Antichain<G::Timestamp>,
) -> (Box<dyn Push<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.