Enum StreamingStep 

pub enum StreamingStep {
    ClusterGroup {
        key: DecoratedKey,
        row: Box<MergeEntry>,
    },
    PartitionEnd {
        key: DecoratedKey,
    },
    Complete,
}

A single streaming increment from StreamingMerger::step_streaming (issue #1668, stage 2). Distinct from [MergeStep] (unchanged, still the production shape) so no existing match/while let MergeStep::Partition call site anywhere in the codebase is affected by this addition.

Variants

ClusterGroup

One already-reconciled row belonging to key’s partition, in the SAME relative order MergeStep::Partition { rows, .. } would have held it (range/partition-tombstone carriers first, then clustering rows in schema-aware clustering order — see merge_partition_rows).

Fields

key: DecoratedKey

Partition key this row belongs to.

row: Box<MergeEntry>

The reconciled row (or carrier re-emission). Boxed: Complete is zero-sized, so an inline MergeEntry here would trip clippy::large_enum_variant (denied crate-wide, lib.rs).

PartitionEnd

No more ClusterGroups remain for key’s partition.

Fields

key: DecoratedKey

Partition key whose cluster groups are exhausted.

Complete

The merge is complete (no more partitions in any run).

Trait Implementations

impl Clone for StreamingStep

fn clone(&self) -> StreamingStep

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingStep

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

Formats the value using the given formatter.

impl Eq for StreamingStep

impl PartialEq for StreamingStep

fn eq(&self, other: &StreamingStep) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamingStep