Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/21054#discussion_r185409726
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/Corr.scala
---
@@ -51,7 +47,27 @@ case class Corr(x: Expression, y: Expression)
override val initialValues: Seq[Expression] = Array.fill(6)(Literal(0.0))
- override val updateExpressions: Seq[Expression] = {
+ override lazy val updateExpressions: Seq[Expression] =
updateExpressionsDef
+
+ override val mergeExpressions: Seq[Expression] = {
+
--- End diff --
nit: Remove the blank line (I know this is not related to this pr though...)
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
