Module datafusion_physical_plan::aggregates

Aggregates functionalities

Modules

• group_values
• 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
  Hash aggregate modes

Functions

• aggregate_expressions
  Returns physical expressions for arguments to evaluate against a batch.
• concat_slices
  Concatenates the given slices.
• create_accumulators
• 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
  Get the common requirement that satisfies all the aggregate expressions.

Type Aliases

• AccumulatorItem