Struct MergeBatcher

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

Creates batches from containers of unordered tuples.

To implement Batcher, the container builder C must accept &mut Input as inputs, and must produce outputs of type M::Chunk.

Trait Implementations

impl<Input, C, M> Batcher for MergeBatcher<Input, C, M>

where C: ContainerBuilder<Container = M::Chunk> + for<'a> PushInto<&'a mut Input>, M: Merger<Time: Timestamp>,

fn push_container(&mut self, container: &mut Input)

Push a container of data into this merge batcher. Updates the internal chain structure if needed.

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

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

type Input = Input

Type pushed into the batcher.

type Time = <M as Merger>::Time

Times at which batches are formed.

type Output = <M as Merger>::Chunk

Type produced by the batcher.

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

Allocates a new empty batcher.

fn seal<B: Builder<Input = Self::Output, Time = Self::Time>>( &mut self, upper: Antichain<M::Time>, ) -> B::Output

Returns all updates not greater or equal to an element of upper.

impl<Input, C, M: Merger> Drop for MergeBatcher<Input, C, M>

fn drop(&mut self)

Executes the destructor for this type.