Trait differential_dataflow::trace::Batcher [−][src]
Functionality for collecting and batching updates.
Required methods
fn new() -> Self
[src]
Allocates a new empty batcher.
fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)
[src]
Adds an unordered batch of elements to the batcher.
fn seal(&mut self, upper: Antichain<T>) -> Output
[src]
Returns all updates not greater or equal to an element of upper
.
fn frontier(&mut self) -> AntichainRef<'_, T>
[src]
Returns the lower envelope of contained update times.
Implementors
impl<K, V, T, R, B> Batcher<K, V, T, R, B> for MergeBatcher<K, V, T, R, B> where
K: Ord + Clone,
V: Ord + Clone,
T: Lattice + Timestamp + Ord + Clone,
R: Semigroup,
B: Batch<K, V, T, R>,
[src]
K: Ord + Clone,
V: Ord + Clone,
T: Lattice + Timestamp + Ord + Clone,
R: Semigroup,
B: Batch<K, V, T, R>,
fn new() -> Self
[src]
fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)
[src]
fn seal(&mut self, upper: Antichain<T>) -> B
[src]
fn frontier(&mut self) -> AntichainRef<'_, T>
[src]
impl<K, V, T, R, B: Batch<K, V, T, R> + Abomonation> Batcher<K, V, T, R, Abomonated<B, Vec<u8, Global>>> for AbomonatedBatcher<K, V, T, R, B>
[src]
Functionality for collecting and batching updates.
fn new() -> Self
[src]
fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)
[src]
fn seal(&mut self, upper: Antichain<T>) -> Abomonated<B, Vec<u8>>
[src]
fn frontier(&mut self) -> AntichainRef<'_, T>
[src]
impl<K, V, T, R, B: Batch<K, V, T, R>> Batcher<K, V, T, R, Rc<B>> for RcBatcher<K, V, T, R, B>
[src]
Functionality for collecting and batching updates.