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

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

Creates batches from unordered tuples.

Trait Implementations

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

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

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

type Input = Input

Type pushed into the batcher.

type Output = <M as Merger>::Output

Type produced by the batcher.

type Time = T

Times at which batches are formed.

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

Allocates a new empty batcher.

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

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

impl<Input, C, M, T> Drop for MergeBatcher<Input, C, M, T>

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

fn drop(&mut self)

Executes the destructor for this type.