Struct differential_dataflow::trace::rc_blanket_impls::RcBuilder

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

Wrapper type for building reference counted batches.

Trait Implementations

impl<B: Builder> Builder for RcBuilder<B>

Functionality for building batches from ordered update sequences.

type Input = <B as Builder>::Input

Input item type.

type Time = <B as Builder>::Time

Timestamp type.

type Output = Rc<<B as Builder>::Output>

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, input: &mut Self::Input)

Adds a chunk of elements to the batch.

fn done(self, description: Description<Self::Time>) -> Rc<B::Output>

Completes building and returns the batch.

fn seal( chain: &mut Vec<Self::Input>, description: Description<Self::Time>, ) -> Self::Output

Builds a batch from a chain of updates corresponding to the indicated lower and upper bounds.

fn new() -> Self

Allocates an empty builder.