Struct BytesCounterMetric 

pub struct BytesCounterMetric { /* private fields */ }

A cumulative counter metric for tracking byte counts.

Unlike DataFusion’s built-in Count which formats large values using plain count notation (e.g., “1.91 B” meaning 1.91 billion), this metric formats values using human_readable_size (e.g., “1.91 GB”).

This avoids the confusing display where “B” (billions) looks like “bytes”.

Aggregation sums values across partitions/tasks.

Implementations

impl BytesCounterMetric

pub fn from_value(bytes: usize) -> Self

pub fn value(&self) -> usize

pub fn add_bytes(&self, bytes: usize) -> usize

Trait Implementations

impl Clone for BytesCounterMetric

fn clone(&self) -> BytesCounterMetric

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CustomMetricValue for BytesCounterMetric

fn new_empty(&self) -> Arc<dyn CustomMetricValue>

Returns a new, zero-initialized version of this metric value.

fn aggregate(&self, other: Arc<dyn CustomMetricValue + 'static>)

Merges another metric value into this one.

fn as_any(&self) -> &dyn Any

Returns this value as a Any to support dynamic downcasting.

fn as_usize(&self) -> usize

Optionally returns a numeric representation of the value, if meaningful. Otherwise will default to zero.

fn is_eq(&self, other: &Arc<dyn CustomMetricValue>) -> bool

Compares this value with another custom value.

impl Debug for BytesCounterMetric

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

Formats the value using the given formatter.

impl Default for BytesCounterMetric

fn default() -> Self

Returns the “default value” for a type.

impl Display for BytesCounterMetric

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

Formats the value using the given formatter.