Struct ColumnatedMergeBatcher

pub struct ColumnatedMergeBatcher<K, V, T, D>
where
    K: Columnation + 'static,
    V: Columnation + 'static,
    T: Columnation + 'static,
    D: Columnation + 'static,
{ /* private fields */ }

Creates batches from unordered tuples.

Trait Implementations

impl<K, V, T, D> Batcher for ColumnatedMergeBatcher<K, V, T, D>

where K: Columnation + Ord + Clone + 'static, V: Columnation + Ord + Clone + 'static, T: Columnation + Timestamp + 'static, D: Columnation + Semigroup + 'static,

fn frontier(&mut self) -> AntichainRef<'_, T>

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

type Item = ((K, V), T, D)

Type of update pushed into 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 push_batch(&mut self, batch: RefOrMut<'_, Vec<Self::Item>>)

Adds an unordered batch of elements to the batcher.

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

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