Struct differential_dataflow::trace::implementations::Batcher
source · pub struct Batcher<K, V, T, D> { /* private fields */ }
Expand description
Creates batches from unordered tuples.
Trait Implementations§
source§impl<K, V, T, D> Batcher for MergeBatcher<K, V, T, D>where
K: Ord + Clone,
V: Ord + Clone,
T: Timestamp,
D: Semigroup,
impl<K, V, T, D> Batcher for MergeBatcher<K, V, T, D>where K: Ord + Clone, V: Ord + Clone, T: Timestamp, D: Semigroup,
source§fn push_batch(&mut self, batch: RefOrMut<'_, Vec<Self::Item>>)
fn push_batch(&mut self, batch: RefOrMut<'_, Vec<Self::Item>>)
Adds an unordered batch of elements to the batcher.
source§fn seal<B: Builder<Item = Self::Item, Time = Self::Time>>(
&mut self,
upper: Antichain<T>
) -> B::Output
fn seal<B: Builder<Item = Self::Item, Time = Self::Time>>( &mut self, upper: Antichain<T> ) -> B::Output
Returns all updates not greater or equal to an element of
upper
.source§fn frontier(&mut self) -> AntichainRef<'_, T>
fn frontier(&mut self) -> AntichainRef<'_, T>
Returns the lower envelope of contained update times.
Auto Trait Implementations§
impl<K, V, T, D> RefUnwindSafe for MergeBatcher<K, V, T, D>where D: RefUnwindSafe, K: RefUnwindSafe, T: RefUnwindSafe, V: RefUnwindSafe,
impl<K, V, T, D> Send for MergeBatcher<K, V, T, D>where D: Send, K: Send, T: Send, V: Send,
impl<K, V, T, D> Sync for MergeBatcher<K, V, T, D>where D: Sync, K: Sync, T: Sync, V: Sync,
impl<K, V, T, D> Unpin for MergeBatcher<K, V, T, D>where D: Unpin, K: Unpin, T: Unpin, V: Unpin,
impl<K, V, T, D> UnwindSafe for MergeBatcher<K, V, T, D>where D: UnwindSafe, K: UnwindSafe, T: UnwindSafe, V: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more