Skip to content

BaseAggregateExec — Aggregate Unary Physical Operators

BaseAggregateExec is an extension of the UnaryExecNode abstraction for aggregate unary physical operators.

Contract

Aggregate Attributes

aggregateAttributes: Seq[Attribute]

Aggregate Attributes

Aggregate Functions

aggregateExpressions: Seq[AggregateExpression]

AggregateExpressions

Grouping Keys

groupingExpressions: Seq[NamedExpression]

Grouping NamedExpressions

Required Child Distribution Expressions

requiredChildDistributionExpressions: Option[Seq[Expression]]

Used when:

Results

resultExpressions: Seq[NamedExpression]

Result NamedExpressions

Implementations

AliasAwareOutputPartitioning

BaseAggregateExec is an AliasAwareOutputPartitioning.

Detailed Description (with Operator Id)

verboseStringWithOperatorId(): String

verboseStringWithOperatorId is part of the QueryPlan abstraction.

verboseStringWithOperatorId returns the following text (with the formattedNodeName and the others):

[formattedNodeName]
Input: [child.output]
Keys: [groupingExpressions]
Functions: [aggregateExpressions]
Aggregate Attributes: [aggregateAttributes]
Results: [resultExpressions]

Required Child Output Distribution

requiredChildDistribution: List[Distribution]

requiredChildDistribution is part of the SparkPlan abstraction.

requiredChildDistribution...FIXME


Last update: 2021-07-05
Back to top