Struct ChunkMerger 

pub struct ChunkMerger<C> { /* private fields */ }

A merge-batcher Merger over chains of Chunks.

merge runs the whole-chain binary merger; extract splits by the seal frontier using Chunk::extract. The batcher consolidates equal (data, time) updates but does not advance times — time advancement is advance’s job, handled later in the trace. Both settle their output, since the batcher’s chains want to be graded.

Trait Implementations

impl<C> Default for ChunkMerger<C>

fn default() -> Self

Returns the “default value” for a type.

impl<C> Merger for ChunkMerger<C>

where C: Chunk + Default + 'static, C::Time: Clone + PartialOrder + 'static,

type Chunk = C

The internal representation of chunks of data.

type Time = <C as Chunk>::Time

The type of time in frontiers to extract updates.

fn merge( &mut self, list1: Vec<C>, list2: Vec<C>, output: &mut Vec<C>, _stash: &mut Vec<C>, )

Merge chains into an output chain.

fn extract( &mut self, merged: Vec<C>, upper: AntichainRef<'_, C::Time>, frontier: &mut Antichain<C::Time>, ship: &mut Vec<C>, kept: &mut Vec<C>, _stash: &mut Vec<C>, )

Extract ready updates based on the upper frontier.

fn len(chunk: &C) -> usize

The number of updates in a chunk.

fn allocation(_chunk: &Self::Chunk) -> (usize, usize, usize)

Backing-allocation figures for a chunk: (size, capacity, allocations), for the size logger’s memory telemetry.