pub struct AbomonatedBatcher<B: Batch> { /* private fields */ }
Expand description
Wrapper type for batching reference counted batches.
Trait Implementations§
source§impl<B: Batch + Abomonation> Batcher<Abomonated<B, Vec<u8>>> for AbomonatedBatcher<B>
impl<B: Batch + Abomonation> Batcher<Abomonated<B, Vec<u8>>> for AbomonatedBatcher<B>
Functionality for collecting and batching updates.
source§fn push_batch(
&mut self,
batch: RefOrMut<'_, Vec<((B::Key, B::Val), B::Time, B::R)>>
)
fn push_batch( &mut self, batch: RefOrMut<'_, Vec<((B::Key, B::Val), B::Time, B::R)>> )
Adds an unordered batch of elements to the batcher.
source§fn seal(&mut self, upper: Antichain<B::Time>) -> Abomonated<B, Vec<u8>>
fn seal(&mut self, upper: Antichain<B::Time>) -> Abomonated<B, Vec<u8>>
Returns all updates not greater or equal to an element of
upper
.source§fn frontier(&mut self) -> AntichainRef<'_, B::Time>
fn frontier(&mut self) -> AntichainRef<'_, B::Time>
Returns the lower envelope of contained update times.
Auto Trait Implementations§
impl<B> RefUnwindSafe for AbomonatedBatcher<B>where <B as Batch>::Batcher: RefUnwindSafe,
impl<B> Send for AbomonatedBatcher<B>where <B as Batch>::Batcher: Send,
impl<B> Sync for AbomonatedBatcher<B>where <B as Batch>::Batcher: Sync,
impl<B> Unpin for AbomonatedBatcher<B>where <B as Batch>::Batcher: Unpin,
impl<B> UnwindSafe for AbomonatedBatcher<B>where <B as Batch>::Batcher: 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