Struct ChunkBatch 

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

A batch is a Chunk sequence plus a Description.

Fields

chunks: Vec<C>

Ordered, consolidated chunks; their concatenation is the batch.

description: Description<C::Time>

The lower, upper, and since frontiers of the batch.

Implementations

impl<C: Chunk> ChunkBatch<C>

pub fn new(chunks: Vec<C>, description: Description<C::Time>) -> Self

Assemble a batch from ordered chunks.

Trait Implementations

impl<C: Chunk + Default + 'static> Batch for ChunkBatch<C>

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

type Merger = ChunkBatchMerger<C>

A type used to progressively merge batches.

fn empty(lower: Antichain<Self::Time>, upper: Antichain<Self::Time>) -> Self

Produce an empty batch over the indicated interval.

fn begin_merge( &self, other: &Self, compaction_frontier: AntichainRef<'_, Self::Time>, ) -> Self::Merger

Initiates the merging of consecutive batches.

impl<C: Chunk> BatchReader for ChunkBatch<C>

type Time = <C as Chunk>::Time

The timestamp type of the batch’s updates.

fn len(&self) -> usize

The number of updates in the batch.

fn description(&self) -> &Description<Self::Time>

Describes the times of the updates in the batch.

fn is_empty(&self) -> bool

True if the batch is empty.

fn lower(&self) -> &Antichain<Self::Time>

All times in the batch are greater or equal to an element of lower.

fn upper(&self) -> &Antichain<Self::Time>

All times in the batch are not greater or equal to any element of upper.

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

where C: Chunk + Default + '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) -> ChunkBatch<C>

Extracts merged results.

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.