Struct mz_timely_util::operator::ConsolidateBuilder

struct ConsolidateBuilder<K: Data, V: Data, T: Timestamp, R: Data, O> {
    buffer: Vec<Vec<((K, V), T, R)>>,
    _marker: PhantomData<O>,
}

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

Fields

buffer: Vec<Vec<((K, V), T, R)>>

_marker: PhantomData<O>

Trait Implementations

impl<K, V, T, R, O> Builder for ConsolidateBuilder<K, V, T, R, O>

where K: Data, V: Data, T: Timestamp, R: Data, O: Container, for<'a> Vec<((K, V), T, R)>: PushInto<O::Item<'a>>,

type Input = O

Input item type.

type Time = T

Timestamp type.

type Output = Vec<Vec<((K, V), T, R)>>

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, _lower: Antichain<Self::Time>, _upper: Antichain<Self::Time>, _since: Antichain<Self::Time>, ) -> Self::Output

Completes building and returns the batch.