Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185409402
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/CentralMomentAgg.scala
---
@@ -128,6 +100,36 @@ abstract class CentralMomentAgg(child: Expression)
trimHigherOrder(Seq(newN, newAvg, newM2, newM3, newM4))
}
+
+ def updateExpressionsDef: Seq[Expression] = {
--- End diff --
`protected def`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
