Struct ChunkBatch 

pub struct ChunkBatch<C: Chunk> {
    pub chunks: Vec<C>,
}

A batch: an ordered Chunk sequence whose concatenation is its updates.

Fields

chunks: Vec<C>

Ordered, consolidated chunks; their concatenation is the batch.

Implementations

impl<C: Chunk> ChunkBatch<C>

pub fn new(chunks: Vec<C>) -> Self

Assemble a batch from ordered chunks.

Trait Implementations

impl<C> Merger<ChunkBatch<C>> for ChunkBatchMerger<C>

where C: Chunk + 'static, C::Time: Timestamp + Lattice + Ord + 'static,

fn new( _source1: &ChunkBatch<C>, _source2: &ChunkBatch<C>, frontier: AntichainRef<'_, C::Time>, ) -> Self

Creates a new merger to merge the supplied batches, optionally compacting up to the supplied frontier.

fn work( &mut self, source1: &ChunkBatch<C>, source2: &ChunkBatch<C>, fuel: &mut isize, )

Perform some amount of work, decrementing fuel.

fn done(self) -> Option<ChunkBatch<C>>

Extracts merged results, absent if the merge cancelled to nothing.

impl<C: NavigableChunk> Navigable for ChunkBatch<C>

type Cursor = ChunkBatchCursor<C>

The cursor type.

fn cursor(&self) -> Self::Cursor

Acquire a cursor suitable for the instance.

impl<C: Chunk + 'static> SpineBatch for ChunkBatch<C>

where C::Time: Timestamp + Lattice + Ord,

type Time = <C as Chunk>::Time

The timestamp type of the batch’s updates.

type Merger = ChunkBatchMerger<C>

A type used to progressively merge batches.

fn len(&self) -> usize

The number of updates in the batch.