(Changed in version 2.8.0) collect
has changed. The previous behavior can be reproduced with toSeq
.
Initializes buffer values for all aggregate functions.
Initializes buffer values for all aggregate functions.
Processes rows in the current group.
Processes rows in the current group. It will stop when it find a new group.
An iterator used to evaluate AggregateFunction. It assumes the input rows have been sorted by values of groupingExpressions.