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.
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.