Struct differential_dataflow::trace::abomonated_blanket_impls::AbomonatedBatcher
[−]
[src]
pub struct AbomonatedBatcher<K, V, T, R, B: Batch<K, V, T, R>> { /* fields omitted */ }
Wrapper type for batching reference counted batches.
Trait Implementations
impl<K, V, T, R, B: Batch<K, V, T, R> + Abomonation> Batcher<K, V, T, R, Abomonated<B, Vec<u8>>> for AbomonatedBatcher<K, V, T, R, B>[src]
Functionality for collecting and batching updates.
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: &[T]) -> Abomonated<B, Vec<u8>>[src]
Returns all updates not greater or equal to an element of upper.
fn frontier(&mut self) -> &[T][src]
Returns the lower envelope of contained update times.
Auto Trait Implementations
impl<K, V, T, R, B> Send for AbomonatedBatcher<K, V, T, R, B> where
<B as Batch<K, V, T, R>>::Batcher: Send,
<B as Batch<K, V, T, R>>::Batcher: Send,
impl<K, V, T, R, B> Sync for AbomonatedBatcher<K, V, T, R, B> where
<B as Batch<K, V, T, R>>::Batcher: Sync,
<B as Batch<K, V, T, R>>::Batcher: Sync,