Struct ContainerMerger

pub struct ContainerMerger<MC, CQ> { /* private fields */ }

A merger for arbitrary containers.

MC is a Container that implements MergerChunk. CQ is a ContainerQueue supporting MC.

Trait Implementations

impl<MC, CQ> Default for ContainerMerger<MC, CQ>

fn default() -> Self

Returns the “default value” for a type.

impl<MC, CQ> Merger for ContainerMerger<MC, CQ>

where for<'a> MC: MergerChunk + Clone + PushInto<<MC as Container>::Item<'a>> + 'static, for<'a> MC::TimeOwned: Ord + PartialOrder + Data, CQ: ContainerQueue<MC>,

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

Account the allocations behind the chunk.

type Time = <MC as MergerChunk>::TimeOwned

The type of time in frontiers to extract updates.

type Chunk = 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.