spark技术分享PhysicalAggregation — Scala Extractor for Destructuring Aggregate Logical Operators
PhysicalAggregation is a Scala extractor to destructure an Aggregate logical operator into a four-element tuple with the following elements:
-
Grouping named expressions
-
Result named expressions
-
Child logical operator
|
1 2 3 4 5 6 |
ReturnType (Seq[NamedExpression], Seq[AggregateExpression], Seq[NamedExpression], LogicalPlan) |
|
Tip
|
See the document about Scala extractor objects. |
Destructuring Aggregate Logical Operator — unapply Method
|
1 2 3 4 5 6 7 8 |
type ReturnType = (Seq[NamedExpression], Seq[AggregateExpression], Seq[NamedExpression], LogicalPlan) unapply(a: Any): Option[ReturnType] |
unapply destructures the input a Aggregate logical operator into a four-element ReturnType.
|
Note
|
|
