differential_dataflow::trace::wrappers::freeze

Function freeze

Source
pub fn freeze<G, T, F>(
    arranged: &Arranged<G, T>,
    func: F,
) -> Arranged<G, TraceFreeze<T, F>>
where G: Scope<Timestamp = T::Time>, T: TraceReader + Clone, F: Fn(T::TimeGat<'_>) -> Option<T::Time> + 'static,
Expand description

Freezes updates to an arrangement using a supplied function.

This method is experimental, and should be used with care. The intent is that the function func can be used to restrict and lock in updates at a particular time, as suggested in the module-level documentation.