Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20094#discussion_r158855682
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
---
@@ -1404,18 +1384,16 @@ class Analyzer(
*/
object ResolveAggregateFunctions extends Rule[LogicalPlan] {
def apply(plan: LogicalPlan): LogicalPlan = plan.transformUp {
- case filter @ Filter(havingCondition, AnalysisBarrier(aggregate:
Aggregate)) =>
- apply(Filter(havingCondition,
aggregate)).mapChildren(AnalysisBarrier)
- case filter @ Filter(havingCondition,
- aggregate @ Aggregate(grouping, originalAggExprs, child))
- if aggregate.resolved =>
+ case Filter(cond, AnalysisBarrier(agg: Aggregate)) =>
+ apply(Filter(cond, agg)).mapChildren(AnalysisBarrier)
+ case f @ Filter(cond, agg @ Aggregate(grouping, originalAggExprs,
child)) if agg.resolved =>
--- End diff --
just make the names shorter
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
