Struct ConsolidateBuilder

struct ConsolidateBuilder<T, I> {
    _marker: PhantomData<(T, I)>,
}

A builder that wraps a session for direct output to a stream.

Fields

_marker: PhantomData<(T, I)>

Trait Implementations

impl<T, I> Builder for ConsolidateBuilder<T, I>

where T: Timestamp, I: Container,

type Input = I

Input item type.

type Time = T

Timestamp type.

type Output = Vec<I>

Output batch type.

fn new() -> Self

Allocates an empty builder.

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, _: Description<Self::Time>) -> Self::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.