Struct differential_dataflow::trace::implementations::merge_batcher_flat::FlatcontainerMerger

pub struct FlatcontainerMerger<MC> { /* private fields */ }

A merger for flat stacks.

MC is a Region that implements MergerChunk.

Trait Implementations

impl<MC> Default for FlatcontainerMerger<MC>

fn default() -> Self

Returns the “default value” for a type.

impl<MC> Merger for FlatcontainerMerger<MC>

where for<'a> MC: MergerChunk + Clone + 'static + ReserveItems<<MC as Region>::ReadItem<'a>> + Push<<MC as Region>::ReadItem<'a>> + Push<(MC::Data<'a>, MC::Time<'a>, &'a MC::DiffOwned)> + Push<(MC::Data<'a>, MC::Time<'a>, MC::Diff<'a>)>, for<'a> MC::Time<'a>: PartialOrder<MC::TimeOwned> + Copy + IntoOwned<'a, Owned = MC::TimeOwned>, for<'a> MC::Diff<'a>: IntoOwned<'a, Owned = MC::DiffOwned>, for<'a> MC::TimeOwned: Ord + PartialOrder + PartialOrder<MC::Time<'a>> + Data, for<'a> MC::DiffOwned: Default + Semigroup + Semigroup<MC::Diff<'a>> + Data,

type Time = <MC as MergerChunk>::TimeOwned

The type of time in frontiers to extract updates.

type Chunk = FlatStack<MC>

The internal representation of chunks of data.

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 account(chunk: &Self::Chunk) -> (usize, usize, usize, usize)

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