Enum sql::plan::expr::AggregateFunc

pub enum AggregateFunc {
    MaxNumeric,
    MaxInt16,
    MaxInt32,
    MaxInt64,
    MaxFloat32,
    MaxFloat64,
    MaxBool,
    MaxString,
    MaxDate,
    MaxTimestamp,
    MaxTimestampTz,
    MinNumeric,
    MinInt16,
    MinInt32,
    MinInt64,
    MinFloat32,
    MinFloat64,
    MinBool,
    MinString,
    MinDate,
    MinTimestamp,
    MinTimestampTz,
    SumInt16,
    SumInt32,
    SumInt64,
    SumFloat32,
    SumFloat64,
    SumNumeric,
    Count,
    Any,
    All,
    JsonbAgg {
        order_by: Vec<ColumnOrder>,
    },
    JsonbObjectAgg {
        order_by: Vec<ColumnOrder>,
    },
    ArrayConcat {
        order_by: Vec<ColumnOrder>,
    },
    ListConcat {
        order_by: Vec<ColumnOrder>,
    },
    StringAgg {
        order_by: Vec<ColumnOrder>,
    },
    Dummy,
}

Aggregate functions analogous to expr::AggregateFunc, but whose types may be different.

Specifically, the nullability of the aggregate columns is more common here than in expr, as these aggregates may be applied over empty result sets and should be null in those cases, whereas expr variants only return null values when supplied nulls as input.

Variants

MaxNumeric

MaxInt16

MaxInt32

MaxInt64

MaxFloat32

MaxFloat64

MaxBool

MaxString

MaxDate

MaxTimestamp

MaxTimestampTz

MinNumeric

MinInt16

MinInt32

MinInt64

MinFloat32

MinFloat64

MinBool

MinString

MinDate

MinTimestamp

MinTimestampTz

SumInt16

SumInt32

SumInt64

SumFloat32

SumFloat64

SumNumeric

Count

Any

All

JsonbAgg

Fields

order_by: Vec<ColumnOrder>

Accumulates Datum::Lists whose first element is a JSON-typed Datums into a JSON list. The other elements are columns used by order_by.

WARNING: Unlike the jsonb_agg function that is exposed by the SQL layer, this function filters out Datum::Null, for consistency with the other aggregate functions.

JsonbObjectAgg

Fields

order_by: Vec<ColumnOrder>

Zips Datum::Lists whose first element is a JSON-typed Datums into a JSON map. The other elements are columns used by order_by.

ArrayConcat

Fields

order_by: Vec<ColumnOrder>

Accumulates Datum::Lists whose first element is a Datum::Array into a single Datum::Array. The other elements are columns used by order_by.

ListConcat

Fields

order_by: Vec<ColumnOrder>

Accumulates Datum::Lists whose first element is a Datum::List into a single Datum::List. The other elements are columns used by order_by.

StringAgg

Fields

order_by: Vec<ColumnOrder>

Dummy

Accumulates any number of Datum::Dummys into Datum::Dummy.

Useful for removing an expensive aggregation while maintaining the shape of a reduce operator.

Implementations

impl AggregateFunc

pub fn into_expr(self) -> AggregateFunc

Converts the sql::AggregateFunc to a corresponding expr::AggregateFunc.

pub fn identity_datum(&self) -> Datum<'static>

Returns a datum whose inclusion in the aggregation will not change its result.

pub fn output_type(&self, input_type: ColumnType) -> ColumnType

The output column type for the result of an aggregation.

The output column type also contains nullability information, which is (without further information) true for aggregations that are not counts.

pub fn is_order_sensitive(&self) -> bool

Trait Implementations

impl Clone for AggregateFunc

fn clone(&self) -> AggregateFunc

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AggregateFunc

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

Formats the value using the given formatter.

impl From<AggregateFunc> for Operation<(HirScalarExpr, AggregateFunc)>

fn from(a: AggregateFunc) -> Operation<(HirScalarExpr, AggregateFunc)>

Performs the conversion.

impl Hash for AggregateFunc

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, 

Feeds a slice of this type into the given Hasher.

impl PartialEq<AggregateFunc> for AggregateFunc

fn eq(&self, other: &AggregateFunc) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &AggregateFunc) -> bool

This method tests for !=.

impl Eq for AggregateFunc

impl StructuralEq for AggregateFunc

impl StructuralPartialEq for AggregateFunc