Struct datafusion::logical_expr::function::AccumulatorArgs

pub struct AccumulatorArgs<'a> {
    pub data_type: &'a DataType,
    pub schema: &'a Schema,
    pub ignore_nulls: bool,
    pub sort_exprs: &'a [Expr],
}

AccumulatorArgs contains information about how an aggregate function was called, including the types of its arguments and any optional ordering expressions.

Fields

data_type: &'a DataType

The return type of the aggregate function.

schema: &'a Schema

The schema of the input arguments

ignore_nulls: bool

Whether to ignore nulls.

SQL allows the user to specify IGNORE NULLS, for example:

SELECT FIRST_VALUE(column1) IGNORE NULLS FROM t;

sort_exprs: &'a [Expr]

The expressions in the ORDER BY clause passed to this aggregator.

SQL allows the user to specify the ordering of arguments to the aggregate using an ORDER BY. For example:

SELECT FIRST_VALUE(column1 ORDER BY column2) FROM t;

If no ORDER BY is specified, `sort_exprs`` will be empty.

Implementations

impl<'a> AccumulatorArgs<'a>

pub fn new( data_type: &'a DataType, schema: &'a Schema, ignore_nulls: bool, sort_exprs: &'a [Expr] ) -> AccumulatorArgs<'a>