Struct MergeableAccumulator 

pub struct MergeableAccumulator {
    pub count: i64,
    pub sum: f64,
    pub min: Option<Value>,
    pub max: Option<Value>,
    pub first: Option<Value>,
    pub sum_squared: f64,
}

Accumulator state that supports merging.

Used by aggregate operators to merge partial aggregations.

Fields

count: i64

Count of values.

sum: f64

Sum of values.

min: Option<Value>

Minimum value.

max: Option<Value>

Maximum value.

first: Option<Value>

First value encountered.

sum_squared: f64

For AVG: sum of squared values (for variance if needed).

Implementations

impl MergeableAccumulator

pub fn new() -> Self

Creates a new empty accumulator.

pub fn add(&mut self, value: &Value)

Adds a value to the accumulator.

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

Merges another accumulator into this one.

pub fn finalize_count(&self) -> Value

Finalizes COUNT aggregate.

pub fn finalize_sum(&self) -> Value

Finalizes SUM aggregate.

pub fn finalize_min(&self) -> Value

Finalizes MIN aggregate.

pub fn finalize_max(&self) -> Value

Finalizes MAX aggregate.

pub fn finalize_avg(&self) -> Value

Finalizes AVG aggregate.

pub fn finalize_first(&self) -> Value

Finalizes FIRST aggregate.

Trait Implementations

impl Clone for MergeableAccumulator

fn clone(&self) -> MergeableAccumulator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MergeableAccumulator

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

Formats the value using the given formatter.

impl Default for MergeableAccumulator

fn default() -> Self

Returns the “default value” for a type.