Struct mz_persist::metrics::ColumnarMetrics
source · pub struct ColumnarMetrics {
pub(crate) lgbytes_arrow: LgBytesOpMetrics,
pub(crate) parquet: ParquetMetrics,
pub(crate) arrow: ArrowMetrics,
pub(crate) cfg: Arc<ConfigSet>,
pub(crate) is_cc_active: bool,
}
Expand description
Metrics for ColumnarRecords
.
Fields§
§lgbytes_arrow: LgBytesOpMetrics
§parquet: ParquetMetrics
§arrow: ArrowMetrics
§cfg: Arc<ConfigSet>
§is_cc_active: bool
Implementations§
source§impl ColumnarMetrics
impl ColumnarMetrics
sourcepub fn new(
registry: &MetricsRegistry,
lgbytes: &LgBytesMetrics,
cfg: Arc<ConfigSet>,
is_cc_active: bool,
) -> Self
pub fn new( registry: &MetricsRegistry, lgbytes: &LgBytesMetrics, cfg: Arc<ConfigSet>, is_cc_active: bool, ) -> Self
Returns a new ColumnarMetrics.
sourcepub fn arrow(&self) -> &ArrowMetrics
pub fn arrow(&self) -> &ArrowMetrics
Returns a reference to the arrow
metrics for our structured data representation.
sourcepub fn parquet(&self) -> &ParquetMetrics
pub fn parquet(&self) -> &ParquetMetrics
Returns a reference to the parquet
metrics for our structured data representation.
sourcepub fn disconnected() -> Self
pub fn disconnected() -> Self
Returns a ColumnarMetrics disconnected from any metrics registry.
Exposed for testing.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ColumnarMetrics
impl !RefUnwindSafe for ColumnarMetrics
impl Send for ColumnarMetrics
impl Sync for ColumnarMetrics
impl Unpin for ColumnarMetrics
impl !UnwindSafe for ColumnarMetrics
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
Creates a shared type from an unshared type.
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
.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
.