Struct differential_dataflow::trace::implementations::merge_batcher::MergeBatcher

pub struct MergeBatcher<Input, C, M>
where
    C: ContainerBuilder<Container = M::Chunk>,
    M: Merger,
{ /* private fields */ }

Creates batches from unordered tuples.

Trait Implementations

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

where C: ContainerBuilder<Container = M::Chunk> + Default + for<'a> PushInto<&'a mut Input>, M: Merger, M::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<DifferentialEvent>>, 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> Drop for MergeBatcher<Input, C, M>

where C: ContainerBuilder<Container = M::Chunk> + Default, M: Merger,

fn drop(&mut self)

Executes the destructor for this type.