Enum 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>,
    },
    RowNumber {
        order_by: Vec<ColumnOrder>,
    },
    Dummy,
}

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.

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

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 of ScalarType::Record whose first field is a Datum::List into a single Datum::List (the remaining fields are used by order_by).

StringAgg

Fields

order_by: Vec<ColumnOrder>

RowNumber

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 eval<'a, I>(&self, datums: I, temp_storage: &'a RowArena) -> Datum<'a> where
    I: IntoIterator<Item = Datum<'a>>, 

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

Returns the output of the aggregation function when applied on an empty input relation.

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 propagates_nonnull_constraint(&self) -> bool

Returns true if the non-null constraint on the aggregation can be converted into a non-null constraint on its parameter expression, ie. whether the result of the aggregation is null if all the input values are null.

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<'de> Deserialize<'de> for AggregateFunc

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Display for AggregateFunc

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

Formats the value using the given formatter.

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 MzReflect for AggregateFunc

fn add_to_reflected_type_info(rti: &mut ReflectedTypeInfo)

Adds names and types of the fields of the struct or enum to rti.

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 Serialize for AggregateFunc

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

Serialize this value into the given Serde serializer.

impl Eq for AggregateFunc

impl StructuralEq for AggregateFunc

impl StructuralPartialEq for AggregateFunc