Struct OperatorSnapshot 

pub struct OperatorSnapshot {
    pub id: usize,
    pub name: String,
    pub backend: BackendKind,
    pub rows_in: u64,
    pub rows_out: u64,
    pub batches: u64,
    pub elapsed_ns: u64,
    pub bytes_h2d: u64,
    pub bytes_d2h: u64,
    pub memory_bytes: u64,
    pub fallback_batches: u64,
}

Snapshot of one operator’s counters.

Fields

id: usize

Registration index.

name: String

Operator display name.

backend: BackendKind

Planned backend.

rows_in: u64

Input rows.

rows_out: u64

Output rows.

batches: u64

Batches processed.

elapsed_ns: u64

Total processing time in nanoseconds.

bytes_h2d: u64

Bytes copied host→device.

bytes_d2h: u64

Bytes copied device→host.

memory_bytes: u64

Currently allocated bytes.

fallback_batches: u64

Batches that ran on the CPU reference although the operator was placed on a device. Zero is the claim “this operator is accelerated”; anything else is the size of the gap between the plan and what ran.

Implementations

impl OperatorSnapshot

pub fn fell_back_entirely(&self) -> bool

true when every batch this operator processed took the CPU reference path — the shape of a GPU deployment that is not using its GPU at all.

pub fn mean_batch_latency_ms(&self) -> f64

Mean per-batch latency in milliseconds (zero when nothing ran).

Trait Implementations

impl Clone for OperatorSnapshot

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperatorSnapshot

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for OperatorSnapshot

impl PartialEq for OperatorSnapshot

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for OperatorSnapshot

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for OperatorSnapshot