Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/18113#discussion_r150391063
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/typedaggregators.scala
---
@@ -44,8 +44,9 @@ class TypedSumDouble[IN](val f: IN => Double) extends
Aggregator[IN, Double, Dou
}
}
+class TypedSumLong[IN](val f: IN => Long)
+ extends Aggregator[IN, Long, Long] {
--- End diff --
unnecessary change.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
