Struct mz_persist_client::fetch::FetchedBlob

pub struct FetchedBlob<K: Codec, V: Codec, T, D> {
    metrics: Arc<Metrics>,
    read_metrics: ReadMetrics,
    buf: FetchedBlobBuf<T>,
    registered_desc: Description<T>,
    migration: PartMigration<K, V>,
    filter: FetchBatchFilter<T>,
    filter_pushdown_audit: bool,
    structured_part_audit: PartDecodeFormat,
    fetch_permit: Option<Arc<MetricsPermits>>,
    _phantom: PhantomData<fn() -> D>,
}

A Blob object that has been fetched, but not at all decoded.

In contrast to FetchedPart, this representation hasn’t yet done parquet decoding.

Fields

metrics: Arc<Metrics>

read_metrics: ReadMetrics

buf: FetchedBlobBuf<T>

registered_desc: Description<T>

migration: PartMigration<K, V>

filter: FetchBatchFilter<T>

filter_pushdown_audit: bool

structured_part_audit: PartDecodeFormat

fetch_permit: Option<Arc<MetricsPermits>>

_phantom: PhantomData<fn() -> D>

Implementations

impl<K: Codec, V: Codec, T: Timestamp + Lattice + Codec64, D> FetchedBlob<K, V, T, D>

pub fn parse(&self) -> ShardSourcePart<K, V, T, D>

Partially decodes this blob into a FetchedPart.

pub fn stats(&self) -> Option<PartStats>

Decodes and returns the pushdown stats for this part, if known.

Trait Implementations

impl<K: Codec, V: Codec, T: Clone, D> Clone for FetchedBlob<K, V, T, D>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K: Debug + Codec, V: Debug + Codec, T: Debug, D: Debug> Debug for FetchedBlob<K, V, T, D>

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

Formats the value using the given formatter.