Struct mz_persist_client::fetch::EncodedPart

pub(crate) struct EncodedPart<T> {
    metrics: ReadMetrics,
    registered_desc: Description<T>,
    part: Arc<BlobTraceBatchPart<T>>,
    needs_truncation: bool,
    ts_rewrite: Option<Antichain<T>>,
}

A Blob object that has been fetched, but has no associated decoding logic.

Fields

metrics: ReadMetrics

registered_desc: Description<T>

part: Arc<BlobTraceBatchPart<T>>

needs_truncation: bool

ts_rewrite: Option<Antichain<T>>

Implementations

impl<T> EncodedPart<T>

where T: Timestamp + Lattice + Codec64,

pub async fn fetch( shard_id: &ShardId, blob: &dyn Blob, metrics: &Metrics, shard_metrics: &ShardMetrics, read_metrics: &ReadMetrics, registered_desc: &Description<T>, part: &BatchPart<T>, ) -> Result<Self, BlobKey>

pub(crate) fn from_inline( metrics: &Metrics, read_metrics: ReadMetrics, desc: Description<T>, x: &LazyInlineBatchPart, ts_rewrite: Option<&Antichain<T>>, ) -> Self

pub(crate) fn from_hollow( metrics: ReadMetrics, registered_desc: Description<T>, part: &HollowBatchPart<T>, parsed: BlobTraceBatchPart<T>, ) -> Self

pub(crate) fn new( metrics: ReadMetrics, registered_desc: Description<T>, printable_name: &str, ts_rewrite: Option<&Antichain<T>>, parsed: BlobTraceBatchPart<T>, ) -> Self

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

pub(crate) fn normalize(&self, metrics: &ColumnarMetrics) -> BlobTraceUpdates

Returns the updates with all truncation / timestamp rewriting applied.

Trait Implementations

impl<T: Clone> Clone for EncodedPart<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for EncodedPart<T>

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

Formats the value using the given formatter.