Enum StreamingAgg 

pub enum StreamingAgg {
    Count,
    Sum(String),
    Mean(String),
    Min(String),
    Max(String),
    Var(String),
    Sd(String),
}

Streamable aggregation operations. Subset of TidyAgg that admits a constant-state per-group accumulator.

Variants

Count

Row count per group.

Sum(String)

Kahan-sum of a numeric column.

Mean(String)

Arithmetic mean of a numeric column.

Min(String)

Minimum value (NaN-aware: NaN never wins).

Max(String)

Maximum value (NaN-aware: NaN never wins).

Var(String)

Sample variance via Welford’s algorithm (numerically stable).

Sd(String)

Sample standard deviation (sqrt of Var).

Trait Implementations

impl Clone for StreamingAgg

fn clone(&self) -> StreamingAgg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingAgg

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

Formats the value using the given formatter.