Enum mz_persist::indexed::encoding::BlobTraceUpdates
source · pub enum BlobTraceUpdates {
Row(ColumnarRecords),
Both(ColumnarRecords, ColumnarRecordsStructuredExt),
}
Expand description
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§
source§impl BlobTraceUpdates
impl BlobTraceUpdates
sourcepub fn records(&self) -> &ColumnarRecords
pub fn records(&self) -> &ColumnarRecords
Return the ColumnarRecords
of the blob.
sourcepub fn structured(&self) -> Option<&ColumnarRecordsStructuredExt>
pub fn structured(&self) -> Option<&ColumnarRecordsStructuredExt>
Return the ColumnarRecordsStructuredExt
of the blob.
sourcepub fn get_or_make_structured<K: Codec, V: Codec>(
&mut self,
key_schema: &K::Schema,
val_schema: &V::Schema,
) -> &ColumnarRecordsStructuredExt
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.
Trait Implementations§
source§impl Clone for BlobTraceUpdates
impl Clone for BlobTraceUpdates
source§fn clone(&self) -> BlobTraceUpdates
fn clone(&self) -> BlobTraceUpdates
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for BlobTraceUpdates
impl Debug for BlobTraceUpdates
source§impl PartialEq for BlobTraceUpdates
impl PartialEq for BlobTraceUpdates
impl StructuralPartialEq for BlobTraceUpdates
Auto Trait Implementations§
impl Freeze for BlobTraceUpdates
impl !RefUnwindSafe for BlobTraceUpdates
impl Send for BlobTraceUpdates
impl Sync for BlobTraceUpdates
impl Unpin for BlobTraceUpdates
impl !UnwindSafe for BlobTraceUpdates
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.