Struct MergeState

struct MergeState<T> {
    batches: ArrayVec<SpineBatch<T>, BATCHES_PER_LEVEL>,
    merge: Option<IdFuelingMerge<T>>,
}

Describes the state of a layer.

A layer can be empty, contain a single batch, or contain a pair of batches that are in the process of merging into a batch for the next layer.

Fields

batches: ArrayVec<SpineBatch<T>, BATCHES_PER_LEVEL>

merge: Option<IdFuelingMerge<T>>

Implementations

impl<T: Timestamp + Lattice> MergeState<T>

fn id(&self) -> Option<SpineId>

An id that covers all the batches in the given merge state, assuming there are any.

fn single(batch: SpineBatch<T>) -> Self

A new single-batch merge state.

fn push_batch(&mut self, batch: SpineBatch<T>)

Push a new batch at this level, checking invariants.

fn len(&self) -> usize

The number of actual updates contained in the level.

fn is_empty(&self) -> bool

True if this merge state contains no updates.

fn is_vacant(&self) -> bool

True if this level contains no batches.

fn is_single(&self) -> bool

True only for a single-batch state.

fn is_full(&self) -> bool

True if this merge cannot hold any more batches. (i.e. for a binary merge tree, true if this layer holds two batches.)

fn complete(&mut self, log: &mut SpineLog<'_, T>) -> Option<SpineBatch<T>>

Immediately complete any merge.

The result is either a batch, if there is a non-trivial batch to return or None if there is no meaningful batch to return.

There is the additional option of input batches.

fn is_complete(&self) -> bool

True iff the layer is a complete merge, ready for extraction.

fn work(&mut self, fuel: &mut isize)

Performs a bounded amount of work towards a merge.

Trait Implementations

impl<T: Clone> Clone for MergeState<T>

fn clone(&self) -> MergeState<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for MergeState<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for MergeState<T>

fn default() -> Self

Returns the “default value” for a type.