Enum PartialState 

pub enum PartialState {
    Count(i64),
    Sum(f64),
    Avg {
        sum: f64,
        count: i64,
    },
    Min(Option<f64>),
    Max(Option<f64>),
    ApproxDistinct(Vec<u8>),
}

Intermediate partial state for a single aggregate function.

Each variant carries the minimum state needed for the merge step to produce a correct final result.

Variants

Count(i64)

Partial count.

Sum(f64)

Partial sum.

Avg

Partial average as (running sum, running count).

Fields

sum: f64

Running sum.

count: i64

Running count.

Min(Option<f64>)

Partial minimum.

Max(Option<f64>)

Partial maximum.

ApproxDistinct(Vec<u8>)

HyperLogLog sketch bytes for approximate distinct count.

Implementations

impl PartialState

pub fn to_aggregate_state(&self) -> AggregateState

Convert to the gossip AggregateState for cluster replication.

pub fn from_aggregate_state(state: &AggregateState) -> Self

Convert from a gossip AggregateState.

impl PartialState

pub fn empty(kind: TwoPhaseKind) -> Self

Create an empty state for the given function kind.

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

Merge another partial state into this one (in place).

Type-mismatched merges are silently ignored.

pub fn finalize(&self) -> f64

Finalize the partial state to an f64 result.

Trait Implementations

impl Clone for PartialState

fn clone(&self) -> PartialState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartialState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PartialState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PartialState

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PartialState