Struct BatchHandoffStats 

pub struct BatchHandoffStats {
    pub input_batches: u64,
    pub input_rows: u64,
    pub output_batches: u64,
    pub output_rows: u64,
}

Per-output batch handoff counters.

input_* counters describe batches observed from the upstream DataFusion stream. output_* counters describe batches accepted by the downstream consumer. Keeping the two sides separate lets later sink-failure handling report only work that was actually accepted downstream.

Fields

input_batches: u64

Batches observed from the upstream query output.

input_rows: u64

Rows observed from the upstream query output.

output_batches: u64

Batches accepted by the downstream consumer.

output_rows: u64

Rows accepted by the downstream consumer.

Implementations

impl BatchHandoffStats

pub fn record_input_batch(&mut self, row_count: usize)

Records one batch observed from the upstream query output.

pub fn record_output_batch(&mut self, row_count: usize)

Records one batch accepted by the downstream consumer.

Trait Implementations

impl Clone for BatchHandoffStats

fn clone(&self) -> BatchHandoffStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BatchHandoffStats

impl Debug for BatchHandoffStats

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

Formats the value using the given formatter.

impl Default for BatchHandoffStats

fn default() -> BatchHandoffStats

Returns the “default value” for a type.

impl Eq for BatchHandoffStats

impl PartialEq for BatchHandoffStats

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BatchHandoffStats