Trait differential_dataflow::trace::Merger
source · pub trait Merger<Output: Batch> {
// Required methods
fn new(
source1: &Output,
source2: &Output,
compaction_frontier: AntichainRef<'_, Output::Time>
) -> Self;
fn work(&mut self, source1: &Output, source2: &Output, fuel: &mut isize);
fn done(self) -> Output;
}
Expand description
Represents a merge in progress.
Required Methods§
sourcefn new(
source1: &Output,
source2: &Output,
compaction_frontier: AntichainRef<'_, Output::Time>
) -> Self
fn new( source1: &Output, source2: &Output, compaction_frontier: AntichainRef<'_, Output::Time> ) -> Self
Creates a new merger to merge the supplied batches, optionally compacting up to the supplied frontier.
Object Safety§
This trait is not object safe.
Implementors§
impl<B: Batch + Abomonation> Merger<Abomonated<B, Vec<u8>>> for AbomonatedMerger<B>
Represents a merge in progress.
impl<B: Batch> Merger<Rc<B>> for RcMerger<B>
Represents a merge in progress.