Struct mz_persist_types::part::Part
source · pub struct Part {
len: usize,
key: DynStructCol,
val: DynStructCol,
ts: ScalarBuffer<i64>,
diff: ScalarBuffer<i64>,
}
Expand description
A structured columnar representation of one blob’s worth of data.
Fields§
§len: usize
§key: DynStructCol
§val: DynStructCol
§ts: ScalarBuffer<i64>
§diff: ScalarBuffer<i64>
Implementations§
source§impl Part
impl Part
sourcepub fn key_ref(&self) -> ColumnsRef
pub fn key_ref(&self) -> ColumnsRef
Returns a ColumnsRef for the key columns.
sourcepub fn val_ref(&self) -> ColumnsRef
pub fn val_ref(&self) -> ColumnsRef
Returns a ColumnsRef for the val columns.
sourcepub fn key_stats(&self) -> Result<StructStats, String>
pub fn key_stats(&self) -> Result<StructStats, String>
Computes a StructStats for the key columns.
sourcepub fn to_key_arrow(&self) -> Option<(Field, StructArray)>
pub fn to_key_arrow(&self) -> Option<(Field, StructArray)>
Returns an arrow
array representing the key
column.
sourcepub fn to_val_arrow(&self) -> Option<(Field, StructArray)>
pub fn to_val_arrow(&self) -> Option<(Field, StructArray)>
Returns an arrow
array representing the val
column.
pub(crate) fn from_arrow<K, KS: Schema<K>, V, VS: Schema<V>>( key_schema: &KS, val_schema: &VS, arrays: &[Arc<dyn Array>], ) -> Result<Self, String>
fn validate(&self) -> Result<(), String>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Part
impl !RefUnwindSafe for Part
impl Send for Part
impl Sync for Part
impl Unpin for Part
impl !UnwindSafe for Part
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> 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
source§impl<T> Pointable for T
impl<T> Pointable 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
.