Type Alias VecBatcher

pub type VecBatcher<K, V, T, R> = MergeBatcher<Vec<((K, V), T, R)>, VecChunker<((K, V), T, R)>, VecMerger<(K, V), T, R>>;

A batcher for ordered lists.

Aliased Type

struct VecBatcher<K, V, T, R> { /* private fields */ }

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>, 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 M: Merger,

fn drop(&mut self)

Executes the destructor for this type.