Skip to main content

read_as_of

differential_dataflow::operators::int_proxy::frontier

Function read_as_of 

Source 
pub fn read_as_of<T, R, K, V>(
    bridge: &mut ProxyBridge<T, R, K, V>,
    since: &Antichain<T>,
) -> bool
where
    T: Timestamp + Lattice,
    R: Semigroup,
    K: Ord,
    V: Ord,
Expand description

Read bridge as of since: times advanced by it, and the bridge consolidated if any moved, as advancing can make records coincide. Returns whether any did; if none, the bridge is as presented, still sorted and consolidated.

Public so that a wrapper for a backend trait defined outside this crate reads its bridges the one way: dogs3’s half-join wrapper reads the arranged side with it.