Struct mz_timely_util::operator::ConsolidateBuilder

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

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

Fields

buffer: Vec<O>

_marker: PhantomData<(T, I)>

Trait Implementations

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

where T: Timestamp, I: Container, for<'a> O: SizableContainer + PushInto<I::Item<'a>>,

type Input = I

Input item type.

type Time = T

Timestamp type.

type Output = Vec<O>

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.