Struct differential_dataflow::trace::abomonated_blanket_impls::AbomonatedBuilder

pub struct AbomonatedBuilder<B: Builder> { /* private fields */ }

Wrapper type for building reference counted batches.

Trait Implementations

impl<B: Builder> Builder for AbomonatedBuilder<B>

where B::Output: Abomonation,

Functionality for building batches from ordered update sequences.

type Item = <B as Builder>::Item

Input item type.

type Time = <B as Builder>::Time

Timestamp type.

type Output = Abomonated<<B as Builder>::Output, Vec<u8>>

Output batch type.

fn with_capacity(keys: usize, vals: usize, upds: usize) -> Self

Allocates an empty builder with capacity for the specified keys, values, and updates.

fn push(&mut self, element: Self::Item)

Adds an element to the batch.

fn copy(&mut self, element: &Self::Item)

Adds an element to the batch.

fn done( self, lower: Antichain<Self::Time>, upper: Antichain<Self::Time>, since: Antichain<Self::Time> ) -> Self::Output

Completes building and returns the batch.

fn new() -> Self

Allocates an empty builder.

fn extend<I: Iterator<Item = Self::Item>>(&mut self, iter: I)

Adds an ordered sequence of elements to the batch.