Enum mz_persist_client::iter::ConsolidationPart

enum ConsolidationPart<T, D, Sort: RowSort<T, D> = CodecSort<T, D>> {
    Queued {
        data: FetchData<T>,
        task: Option<JoinHandle<Result<Result<EncodedPart<T>, HollowRun<T>>>>>,
    },
    Encoded {
        part: Sort::Updates,
        cursor: PartIndices,
    },
}

Variants

Queued

Fields

data: FetchData<T>

task: Option<JoinHandle<Result<Result<EncodedPart<T>, HollowRun<T>>>>>

Encoded

Fields

part: Sort::Updates

cursor: PartIndices

Implementations

impl<T: Timestamp + Codec64 + Lattice, D: Codec64, Sort: RowSort<T, D>> ConsolidationPart<T, D, Sort>

pub(crate) fn from_encoded( part: EncodedPart<T>, force_reconsolidation: bool, metrics: &ColumnarMetrics, sort: &Sort, ) -> Self

fn kvt_lower(&self) -> Option<(Sort::KV<'_>, T)>

pub(crate) fn is_empty(&self) -> bool

This requires a mutable pointer because the cursor may need to scan ahead to find the next valid record.

Trait Implementations

impl<T: Debug, D: Debug, Sort: Debug + RowSort<T, D>> Debug for ConsolidationPart<T, D, Sort>

where Sort::Updates: Debug,

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

Formats the value using the given formatter.