Enum mz_persist::indexed::encoding::BlobTraceUpdates

pub enum BlobTraceUpdates {
    Row(ColumnarRecords),
    Both(ColumnarRecords, ColumnarRecordsStructuredExt),
}

The set of updates that are part of a BlobTraceBatchPart.

Variants

Row(ColumnarRecords)

Legacy format. Keys and Values are encoded into bytes via Codec, then stored in our own columnar-esque struct.

Both(ColumnarRecords, ColumnarRecordsStructuredExt)

Migration format. Keys and Values are encoded into bytes via Codec and structured into an Apache Arrow columnar format.

Implementations

impl BlobTraceUpdates

pub fn len(&self) -> usize

The number of updates.

pub fn records(&self) -> &ColumnarRecords

Return the ColumnarRecords of the blob.

pub fn structured(&self) -> Option<&ColumnarRecordsStructuredExt>

Return the ColumnarRecordsStructuredExt of the blob.

pub fn goodbytes(&self) -> usize

Return the estimated memory usage of the raw data.

pub fn get_or_make_structured<K: Codec, V: Codec>( &mut self, key_schema: &K::Schema, val_schema: &V::Schema, ) -> &ColumnarRecordsStructuredExt

Return the ColumnarRecordsStructuredExt of the blob.

pub fn concat<K: Codec, V: Codec>( updates: Vec<BlobTraceUpdates>, key_schema: &K::Schema, val_schema: &V::Schema, metrics: &ColumnarMetrics, ) -> Result<BlobTraceUpdates>

Concatenate the given records together, column-by-column.

pub fn into_proto(&self) -> ProtoColumnarRecords

See RustType::into_proto.

Trait Implementations

impl Clone for BlobTraceUpdates

fn clone(&self) -> BlobTraceUpdates

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BlobTraceUpdates

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

Formats the value using the given formatter.

impl PartialEq for BlobTraceUpdates

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BlobTraceUpdates