Struct datafusion::physical_plan::metrics::MetricsSet

pub struct MetricsSet { /* private fields */ }

A snapshot of the metrics for a particular operator (dyn ExecutionPlan).

Implementations

impl MetricsSet

pub fn new() -> Self

Create a new container of metrics

pub fn push(&mut self, metric: Arc<Metric>)

Add the specified metric

pub fn iter(&self) -> impl Iterator<Item = &Arc<Metric>>

Returns an interator across all metrics

pub fn output_rows(&self) -> Option<usize>

convenience: return the number of rows produced, aggregated across partitions or None if no metric is present

pub fn spill_count(&self) -> Option<usize>

convenience: return the count of spills, aggregated across partitions or None if no metric is present

pub fn spilled_bytes(&self) -> Option<usize>

convenience: return the total byte size of spills, aggregated across partitions or None if no metric is present

pub fn elapsed_compute(&self) -> Option<usize>

convenience: return the amount of elapsed CPU time spent, aggregated across partitions or None if no metric is present

pub fn sum<F>(&self, f: F) -> Option<MetricValue> where
    F: FnMut(&Metric) -> bool, 

Sums the values for metrics for which f(metric) returns true, and returns the value. Returns None if no metrics match the predicate.

pub fn aggregate_by_partition(&self) -> Self

Returns returns a new derived MetricsSet where all metrics that had the same name and partition=Some(..) have been aggregated together. The resulting MetricsSet has all metrics with Partition=None

pub fn sorted_for_display(self) -> Self

Sort the order of metrics so the “most useful” show up first

pub fn timestamps_removed(self) -> Self

remove all timestamp metrics (for more compact display

Trait Implementations

impl Clone for MetricsSet

fn clone(&self) -> MetricsSet

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsSet

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

Formats the value using the given formatter.

impl Default for MetricsSet

fn default() -> MetricsSet

Returns the “default value” for a type.

impl Display for MetricsSet

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

format the MetricsSet as a single string