Trait Batcher 

pub trait Batcher {
    type Item;
    type Time: Timestamp;

    // Required methods
    fn new(
        logger: Option<Logger<DifferentialEvent, WorkerIdentifier>>,
        operator_id: usize,
    ) -> Self;
    fn push_batch(&mut self, batch: RefOrMut<'_, Vec<Self::Item>>);
    fn seal<B: Builder<Item = Self::Item, Time = Self::Time>>(
        &mut self,
        upper: Antichain<Self::Time>,
    ) -> B::Output;
    fn frontier(&mut self) -> AntichainRef<'_, Self::Time>;
}

Functionality for collecting and batching updates.

Required Associated Types

type Item

Type of update pushed into the batcher.

type Time: Timestamp

Times at which batches are formed.

Required Methods

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<Self::Time>, ) -> B::Output

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

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

Returns the lower envelope of contained update times.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

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,

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

type Time = T

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

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

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

type Time = T