Enum AggState 

pub enum AggState {
    Count(u64),
    SumI {
        sum: i128,
        count: u64,
    },
    SumF {
        sum: f64,
        count: u64,
    },
    AvgI {
        sum: i128,
        count: u64,
    },
    AvgF {
        sum: f64,
        count: u64,
    },
    MinI(i64),
    MaxI(i64),
    MinF(f64),
    MaxF(f64),
    Empty,
}

A mergeable running aggregate state (Phase 8.3). Two states over disjoint row sets merge into the state over their union, so a cached analytical aggregate can be updated by merging in only the delta (newly inserted rows) instead of a full recompute.

Variants

Count(u64)

COUNT(*) or COUNT(col) over n matching rows.

SumI

Int64 SUM: running i128 sum + non-null count.

Fields

sum: i128

count: u64

SumF

Float64 SUM: running f64 sum + non-null count.

Fields

sum: f64

count: u64

AvgI

Int64 AVG: running i128 sum + non-null count (avg = sum/count).

Fields

sum: i128

count: u64

AvgF

Float64 AVG: running f64 sum + non-null count.

Fields

sum: f64

count: u64

MinI(i64)

Int64 MIN/MAX.

MaxI(i64)

MinF(f64)

Float64 MIN/MAX.

MaxF(f64)

Empty

No matching rows observed yet.

Implementations

impl AggState

pub fn merge(self, other: AggState) -> AggState

Combine two states over disjoint row sets into the state over the union.

pub fn point(&self) -> Option<f64>

The scalar point value (f64), or None when there were no inputs.

pub fn from_native( result: NativeAggResult, agg: NativeAgg, ty: Option<TypeId>, ) -> Self

Convert a vectorized NativeAggResult (from the cursor path) into a mergeable AggState, so the incremental cache can be seeded from the fast cold path. ty is the column’s type (None for COUNT(*)).

Trait Implementations

impl Clone for AggState

fn clone(&self) -> AggState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggState

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

Formats the value using the given formatter.

impl PartialEq for AggState

fn eq(&self, other: &AggState) -> 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 AggState