Struct differential_dataflow::trace::rc_blanket_impls::RcMerger
source · pub struct RcMerger<B: Batch> { /* private fields */ }
Expand description
Wrapper type for merging reference counted batches.
Trait Implementations§
source§impl<B: Batch> Merger<Rc<B>> for RcMerger<B>
impl<B: Batch> Merger<Rc<B>> for RcMerger<B>
Represents a merge in progress.
source§fn new(
source1: &Rc<B>,
source2: &Rc<B>,
compaction_frontier: AntichainRef<'_, B::Time>
) -> Self
fn new( source1: &Rc<B>, source2: &Rc<B>, compaction_frontier: AntichainRef<'_, B::Time> ) -> Self
Creates a new merger to merge the supplied batches, optionally compacting
up to the supplied frontier.
Auto Trait Implementations§
impl<B> Freeze for RcMerger<B>
impl<B> RefUnwindSafe for RcMerger<B>
impl<B> Send for RcMerger<B>
impl<B> Sync for RcMerger<B>
impl<B> Unpin for RcMerger<B>
impl<B> UnwindSafe for RcMerger<B>
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
source§impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.