Struct datafusion_expr::function::AccumulatorArgs

pub struct AccumulatorArgs<'a> {
    pub return_type: &'a DataType,
    pub schema: &'a Schema,
    pub ignore_nulls: bool,
    pub ordering_req: &'a [PhysicalSortExpr],
    pub is_reversed: bool,
    pub name: &'a str,
    pub is_distinct: bool,
    pub exprs: &'a [Arc<dyn PhysicalExpr>],
}

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

Fields

return_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;

ordering_req: &'a [PhysicalSortExpr]

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, ordering_req will be empty.

is_reversed: bool

Whether the aggregation is running in reverse order

name: &'a str

The name of the aggregate expression

is_distinct: bool

Whether the aggregate function is distinct.

SELECT COUNT(DISTINCT column1) FROM t;

exprs: &'a [Arc<dyn PhysicalExpr>]

The physical expression of arguments the aggregate function takes.

Trait Implementations

impl<'a> Debug for AccumulatorArgs<'a>

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

Formats the value using the given formatter.