SortBasedAggregationIterator¶

SortBasedAggregationIterator is an AggregationIterator for SortAggregateExec physical operator.

Creating Instance¶

SortBasedAggregationIterator takes the following to be created:

• Partition ID
• Grouping NamedExpressions
• Value Attributes
• Input Iterator of InternalRows
• AggregateExpressions
• Aggregate Attributes
• Initial input buffer offset
• Result NamedExpressions
• Function to create a new MutableProjection given expressions and attributes ((Seq[Expression], Seq[Attribute]) => MutableProjection)
• numOutputRows SQLMetric

SortBasedAggregationIterator is created when:

• SortAggregateExec physical operator is requested to doExecute