Skip to main content

leave_dynamic

differential_dataflow::columnar

Function leave_dynamic 

Source 
pub fn leave_dynamic<K, V, R, TOuter, T>(
    input: Collection<'_, DynTime<TOuter, T>, RecordedUpdates<(K, V, DynTime<TOuter, T>, R)>>,
    level: usize,
) -> Collection<'_, DynTime<TOuter, T>, RecordedUpdates<(K, V, DynTime<TOuter, T>, R)>>
where
    K: Columnar,
    V: Columnar,
    R: Columnar,
    TOuter: Timestamp + Default + Columnar,
    T: Timestamp + Default + Columnar,
    (K, V, DynTime<TOuter, T>, R): ColumnarUpdate<Key = K, Val = V, Time = DynTime<TOuter, T>, Diff = R>,
Expand description

Leave a dynamic iterative scope, truncating PointStamp coordinates.

Uses OperatorBuilder (not unary) for the custom input connection summary that tells timely how the PointStamp is affected (retain level - 1 coordinates).

Consolidates after truncation since distinct PointStamp coordinates can collapse.