Struct MergeBatcher 

pub struct MergeBatcher<M: Merger> { /* private fields */ }

Creates batches from chunks of sorted, consolidated tuples.

Trait Implementations

impl<M> Batcher for MergeBatcher<M>

where M: Merger<Time: Timestamp>,

fn frontier(&mut self) -> AntichainRef<'_, M::Time>

The frontier of elements remaining after the most recent call to self.seal.

type Time = <M as Merger>::Time

Times at which batches are formed.

type Output = <M as Merger>::Chunk

Type produced by the batcher, and also the type it consumes.

fn new(logger: Option<Logger>, operator_id: usize) -> Self

Allocates a new empty batcher.

fn seal( &mut self, upper: Antichain<M::Time>, ) -> (Vec<Self::Output>, Description<M::Time>)

Returns all updates not greater or equal to an element of upper, as a sorted and consolidated chain together with the description that bounds them.

impl<M: Merger> Drop for MergeBatcher<M>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<M: Merger> PushInto<<M as Merger>::Chunk> for MergeBatcher<M>

fn push_into(&mut self, chunk: M::Chunk)

Push item into self.