Trait Builder 

pub trait Builder: Default {
    type Input;
    type Time: Timestamp;
    type Output;

    // Required methods
    fn push(&mut self, chunk: &mut Self::Input);
    fn done(self) -> Option<Self::Output>;
}

Functionality for building batches from ordered update sequences.

Default is the empty builder; a builder discovers its output as it is pushed, and so has no opportunity to size itself in advance.

Required Associated Types

type Input

Input item type.

type Time: Timestamp

Timestamp type.

type Output

Output batch type.

Required Methods

fn push(&mut self, chunk: &mut Self::Input)

Adds a chunk of elements to the batch.

Adds all elements from chunk to the builder and leaves chunk in an undefined state.

fn done(self) -> Option<Self::Output>

Completes building and returns the batch, absent if no updates were pushed.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<C> Builder for ChunkBatchBuilder<C>

where C: Chunk + Default + 'static, C::Time: Timestamp,

type Input = C

type Time = <C as Chunk>::Time

type Output = ChunkBatch<C>

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

where L: for<'a> Layout<KeyContainer: PushInto<CI::Key<'a>>> + Layout<ValContainer: BatchContainer<Owned: Default>> + Layout, CI: BuilderInput<L::KeyContainer, L::ValContainer, Time = Time<L>, Diff = Diff<L>>,

type Input = CI

type Time = <<L as Layout>::TimeContainer as BatchContainer>::Owned

type Output = OrdKeyBatch<L>

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

where L: for<'a> Layout<KeyContainer: PushInto<CI::Key<'a>>, ValContainer: PushInto<CI::Val<'a>>>, CI: for<'a> BuilderInput<L::KeyContainer, L::ValContainer, Time = Time<L>, Diff = Diff<L>>,

type Input = CI

type Time = <<L as Layout>::TimeContainer as BatchContainer>::Owned

type Output = OrdValBatch<L>