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", so this trait is not object safe.

Implementors

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

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