Struct MetricCollector

pub struct MetricCollector {
    current_level: usize,
    pub record_batch_metrics: RecordBatchMetrics,
}

An [ExecutionPlanVisitor] to collect metrics from a [ExecutionPlan].

Fields

current_level: usize

record_batch_metrics: RecordBatchMetrics

Trait Implementations

impl Default for MetricCollector

fn default() -> MetricCollector

Returns the “default value” for a type.

impl ExecutionPlanVisitor for MetricCollector

type Error = !

The type of error returned by this visitor

fn pre_visit(&mut self, plan: &dyn ExecutionPlan) -> Result<bool, Self::Error>

Invoked on an ExecutionPlan plan before any of its child inputs have been visited. If Ok(true) is returned, the recursion continues. If Err(..) or Ok(false) are returned, the recursion stops immediately and the error, if any, is returned to accept

fn post_visit(&mut self, _plan: &dyn ExecutionPlan) -> Result<bool, Self::Error>

Invoked on an ExecutionPlan plan after all of its child inputs have been visited. The return value is handled the same as the return value of pre_visit. The provided default implementation returns Ok(true).