Module aggregates 

Aggregates functionalities

Modules

group_values

GroupValues trait for storing and interning group keys

order

Structs

AggregateExec

Hash aggregate execution plan

PhysicalGroupBy

Represents GROUP BY clause in the plan (including the more general GROUPING SET) In the case of a simple GROUP BY a, b clause, this will contain the expression [a, b] and a single group [false, false]. In the case of GROUP BY GROUPING SETS/CUBE/ROLLUP the planner will expand the expression into multiple groups, using null expressions to align each group. For example, with a group by clause GROUP BY GROUPING SETS ((a,b),(a),(b)) the planner should create a PhysicalGroupBy like

Enums

AggregateMode

Aggregation modes

Functions

aggregate_expressions

Returns physical expressions for arguments to evaluate against a batch.

concat_slices

Concatenates the given slices.

create_accumulators

evaluate_group_by

Evaluate a group by expression against a RecordBatch

evaluate_many

Evaluates expressions against a record batch.

finalize_aggregation

returns a vector of ArrayRefs, where each entry corresponds to either the final value (mode = Final, FinalPartitioned and Single) or states (mode = Partial)

get_finer_aggregate_exprs_requirement

Gets the common requirement that satisfies all the aggregate expressions. When possible, chooses the requirement that is already satisfied by the equivalence properties.

Type Aliases

AccumulatorItem