mz_compute::typedefs::spines

Type Alias ColValBatcher

Source
pub type ColValBatcher<K, V, T, R> = MergeBatcher<Vec<((K, V), T, R)>, ColumnationChunker<((K, V), T, R)>, ColMerger<(K, V), T, R>>;

Aliased Type§

struct ColValBatcher<K, V, T, R> { /* private fields */ }

Trait Implementations

Source§

impl<Input, C, M> Batcher for MergeBatcher<Input, C, M>
where C: ContainerBuilder<Container = <M as Merger>::Chunk> + Default + for<'a> PushInto<&'a mut Input>, M: Merger, <M as Merger>::Time: Timestamp,

Source§

fn push_container(&mut self, container: &mut Input)

Push a container of data into this merge batcher. Updates the internal chain structure if needed.

Source§

fn frontier(&mut self) -> AntichainRef<'_, <M as Merger>::Time>

The frontier of elements remaining after the most recent call to self.seal.

Source§

type Input = Input

Type pushed into the batcher.
Source§

type Time = <M as Merger>::Time

Times at which batches are formed.
Source§

type Output = <M as Merger>::Chunk

Type produced by the batcher.
Source§

fn new( logger: Option<TypedLogger<CapacityContainerBuilder<Vec<(Duration, DifferentialEvent)>>, DifferentialEvent>>, operator_id: usize, ) -> MergeBatcher<Input, C, M>

Allocates a new empty batcher.
Source§

fn seal<B>( &mut self, upper: Antichain<<M as Merger>::Time>, ) -> <B as Builder>::Output
where B: Builder<Input = <MergeBatcher<Input, C, M> as Batcher>::Output, Time = <MergeBatcher<Input, C, M> as Batcher>::Time>,

Returns all updates not greater or equal to an element of upper.
Source§

impl<Input, C, M> Drop for MergeBatcher<Input, C, M>
where M: Merger,

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more