Enum AggValueState 

pub enum AggValueState {
    Count(u64),
    Sum(Value),
    Min(Value),
    Max(Value),
    Avg {
        sum: Value,
        count: u64,
    },
    Collect(Vec<Value>),
    StdDev {
        sum: f64,
        sum_sq: f64,
        count: u64,
    },
    Variance {
        sum: f64,
        sum_sq: f64,
        count: u64,
    },
    Percentile {
        values: Vec<f64>,
        percentile: f64,
    },
    CountIf(u64),
    StringAgg {
        pieces: Vec<String>,
        delimiter: String,
    },
}

State for aggregate function computation over Values.

Variants

Count(u64)

Sum(Value)

Min(Value)

Max(Value)

Avg

Fields

sum: Value

count: u64

Collect(Vec<Value>)

StdDev

Fields

sum: f64

sum_sq: f64

count: u64

Variance

Fields

sum: f64

sum_sq: f64

count: u64

Percentile

Percentile state — collects all non-null values for percentile computation.

Fields

values: Vec<f64>

percentile: f64

CountIf(u64)

COUNT_IF state — counts rows where the condition evaluated to TRUE.

StringAgg

STRING_AGG state — collects string pieces to be concatenated.

Fields

pieces: Vec<String>

delimiter: String

Implementations

impl AggValueState

pub fn new(func: &AggregateFunction) -> Self

Create a new initial state for the given aggregate function.

pub fn update(&mut self, val: &Value)

Update the state with a new input value.

pub fn finalize(&self) -> Value

Finalize the state into a Value.

pub fn merge(&mut self, other: &Self)

Merge another AggValueState into this one (for parallel aggregation).

Trait Implementations

impl Clone for AggValueState

fn clone(&self) -> AggValueState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggValueState

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

Formats the value using the given formatter.