Struct AvgState 

pub struct AvgState {
    pub sum: f64,
    pub count: u64,
}

AVG state — pair (sum, count). Final value is sum / count.

Fields

sum: f64

count: u64

Implementations

impl AvgState

pub fn finalize(self) -> Option<f64>

Final average value. Returns None for an empty state to distinguish “no rows” from 0.0.

Trait Implementations

impl Clone for AvgState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for AvgState

impl Debug for AvgState

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

Formats the value using the given formatter.

impl Mergeable for AvgState

fn merge(&mut self, other: Self)

Combine other into self, leaving self as the merged result and consuming other.

impl SpillCodec for AvgState

fn encode<W: Write>(&self, w: &mut W) -> Result<usize, SpillError>

Encode self into the writer. Returns the number of bytes written so the caller can track per-batch size.

fn decode<R: Read>(r: &mut R) -> Result<Option<Self>, SpillError>

Decode a fresh value from the reader. Reads exactly one element; returns Ok(None) on a clean end-of-file so drain loops can terminate naturally.

fn decode_with_budget<R: Read>( r: &mut R, _budget: &mut SpillDecodeBudget, ) -> Result<Option<Self>, SpillError>

Implementations must admit heap allocations before reserving them. The drain path refuses legacy codecs without a bounded implementation.