Struct differential_dataflow::trace::implementations::merge_batcher_col::ColumnationMerger

pub struct ColumnationMerger<T> { /* private fields */ }

A merger for timely stacks

Trait Implementations

impl<T> Default for ColumnationMerger<T>

fn default() -> Self

Returns the “default value” for a type.

impl<K, V, T, R> Merger for ColumnationMerger<((K, V), T, R)>

where K: Columnation + Ord + Data, V: Columnation + Ord + Data, T: Columnation + Ord + PartialOrder + Data, R: Columnation + Semigroup + 'static,

type Time = T

The type of time in frontiers to extract updates.

type Chunk = TimelyStack<((K, V), T, R)>

The internal representation of chunks of data.

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

The output type TODO: This should be replaced by Chunk or another container once the builder understands building from a complete chain.

fn merge( &mut self, list1: Vec<Self::Chunk>, list2: Vec<Self::Chunk>, output: &mut Vec<Self::Chunk>, stash: &mut Vec<Self::Chunk>, )

Merge chains into an output chain.

fn extract( &mut self, merged: Vec<Self::Chunk>, upper: AntichainRef<'_, Self::Time>, frontier: &mut Antichain<Self::Time>, readied: &mut Vec<Self::Chunk>, kept: &mut Vec<Self::Chunk>, stash: &mut Vec<Self::Chunk>, )

Extract ready updates based on the upper frontier.

fn seal<B: Builder<Input = Self::Output, Time = Self::Time>>( chain: &mut Vec<Self::Chunk>, lower: AntichainRef<'_, Self::Time>, upper: AntichainRef<'_, Self::Time>, since: AntichainRef<'_, Self::Time>, ) -> B::Output

Build from a chain TODO: We can move this entirely to MergeBatcher once builders can accepts chains.

fn account(chunk: &Self::Chunk) -> (usize, usize, usize, usize)

Account size and allocation changes. Returns a tuple of (records, size, capacity, allocations).