Struct FusedNodeMetrics 

pub struct FusedNodeMetrics {

    pub stage_index: usize,
    pub stage_name: String,
    pub effective_name: String,
    pub metrics_level: MetricsLevel,
    pub elements_in: u64,
    pub elements_out: u64,
    pub batches_in: u64,
    pub batches_out: u64,
    pub rows_in: u64,
    pub rows_out: u64,
    pub processing_time: Duration,
    pub backpressure_stall_time: Duration,
    pub queue_depth: Option<usize>,
}

Immutable metrics for one fused graph node.

Scalar stages populate elements_*. Arrow batch stages populate batches_* and rows_*. Typed fused kernels measure a whole execution chunk with a monotonic clock and publish an equal share to the participating nodes; erased nodes measure their individual transitions. Stall time is measured exactly around bounded-buffer/demand waits. Counts are always exact.

Fields

stage_index: usize

stage_name: String

effective_name: String

metrics_level: MetricsLevel

elements_in: u64

elements_out: u64

batches_in: u64

batches_out: u64

rows_in: u64

rows_out: u64

processing_time: Duration

backpressure_stall_time: Duration

queue_depth: Option<usize>

Trait Implementations

impl Clone for FusedNodeMetrics

fn clone(&self) -> FusedNodeMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FusedNodeMetrics

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

Formats the value using the given formatter.

impl Eq for FusedNodeMetrics

impl PartialEq for FusedNodeMetrics

fn eq(&self, other: &FusedNodeMetrics) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FusedNodeMetrics