Struct differential_dataflow::trace::implementations::ord_neu::OrdValBuilder

pub struct OrdValBuilder<L: Layout, CI> { /* private fields */ }

A builder for creating layers from unsorted update tuples.

Trait Implementations

impl<L, CI> Builder for OrdValBuilder<L, CI>

where L: Layout, CI: for<'a> BuilderInput<L::KeyContainer, L::ValContainer, Time = <L::Target as Update>::Time, Diff = <L::Target as Update>::Diff>, for<'a> L::KeyContainer: PushInto<CI::Key<'a>>, for<'a> L::ValContainer: PushInto<CI::Val<'a>>, for<'a> <L::TimeContainer as BatchContainer>::ReadItem<'a>: IntoOwned<'a, Owned = <L::Target as Update>::Time>, for<'a> <L::DiffContainer as BatchContainer>::ReadItem<'a>: IntoOwned<'a, Owned = <L::Target as Update>::Diff>,

type Input = CI

Input item type.

type Time = <<L as Layout>::Target as Update>::Time

Timestamp type.

type Output = OrdValBatch<L>

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

Adds a chunk of elements to the batch.

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

Completes building and returns the batch.

fn new() -> Self

Allocates an empty builder.