Struct differential_dataflow::trace::implementations::ord::OrdKeyMerger

pub struct OrdKeyMerger<L: Layout>where
    <L::Target as Update>::Key: Sized + Clone,{ /* private fields */ }

State for an in-progress merge.

Trait Implementations

impl<L: Layout> Merger<OrdKeyBatch<L>> for OrdKeyMerger<L>where <L::Target as Update>::Key: Sized + Clone, OrdKeyBatch<L>: Batch<Time = <L::Target as Update>::Time>,

fn new( batch1: &OrdKeyBatch<L>, batch2: &OrdKeyBatch<L>, compaction_frontier: AntichainRef<'_, <L::Target as Update>::Time> ) -> Self

Creates a new merger to merge the supplied batches, optionally compacting up to the supplied frontier.

fn done(self) -> OrdKeyBatch<L>

Extracts merged results.

fn work( &mut self, source1: &OrdKeyBatch<L>, source2: &OrdKeyBatch<L>, fuel: &mut isize )

Perform some amount of work, decrementing fuel.