Enum AggregateType 

pub enum AggregateType {
    Count,
    CountDistinct,
    Sum,
    Min,
    Max,
    Avg,
    FirstValue,
    LastValue,
    StdDev,
    StdDevPop,
    Variance,
    VariancePop,
    Median,
    PercentileCont,
    PercentileDisc,
    BoolAnd,
    BoolOr,
    StringAgg,
    ArrayAgg,
    ApproxCountDistinct,
    ApproxPercentile,
    ApproxMedian,
    Covar,
    CovarPop,
    Corr,
    RegrSlope,
    RegrIntercept,
    BitAnd,
    BitOr,
    BitXor,
    Custom,
}

Types of aggregate functions supported.

Variants

Count

COUNT function

CountDistinct

COUNT DISTINCT function

Sum

SUM function

Min

MIN function

Max

MAX function

Avg

AVG function

FirstValue

FIRST_VALUE function

LastValue

LAST_VALUE function

StdDev

Sample standard deviation (STDDEV / STDDEV_SAMP)

StdDevPop

Population standard deviation (STDDEV_POP)

Variance

Sample variance (VARIANCE / VAR_SAMP)

VariancePop

Population variance (VAR_POP / VARIANCE_POP)

Median

Median

PercentileCont

PERCENTILE_CONT (continuous interpolation)

PercentileDisc

PERCENTILE_DISC (discrete, nearest-rank)

BoolAnd

BOOL_AND / EVERY

BoolOr

BOOL_OR / ANY

StringAgg

STRING_AGG / LISTAGG / GROUP_CONCAT

ArrayAgg

ARRAY_AGG

ApproxCountDistinct

APPROX_COUNT_DISTINCT

ApproxPercentile

APPROX_PERCENTILE_CONT

ApproxMedian

APPROX_MEDIAN

Covar

Covariance sample (COVAR_SAMP)

CovarPop

Covariance population (COVAR_POP)

Corr

Pearson correlation (CORR)

RegrSlope

Linear regression slope (REGR_SLOPE)

RegrIntercept

Linear regression intercept (REGR_INTERCEPT)

BitAnd

BIT_AND

BitOr

BIT_OR

BitXor

BIT_XOR

Custom

Custom / unrecognized aggregate function

Implementations

impl AggregateType

pub fn is_order_sensitive(&self) -> bool

Check if this aggregate is order-sensitive. Order-sensitive aggregates require maintaining event order.

pub fn is_decomposable(&self) -> bool

Check if this aggregate is decomposable (can be computed incrementally).

Decomposable aggregates can be split into partial and final steps, enabling parallel or distributed computation.

pub fn datafusion_name(&self) -> Option<&'static str>

Returns the DataFusion function registry name for this aggregate type, or None if not directly mappable.

pub fn arity(&self) -> usize

Returns the number of input columns required by this aggregate.

Trait Implementations

impl Clone for AggregateType

fn clone(&self) -> AggregateType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggregateType

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

Formats the value using the given formatter.

impl Hash for AggregateType

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for AggregateType

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

impl Eq for AggregateType

impl StructuralPartialEq for AggregateType