Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Incomplete
-
None
-
None
Description
scala> import org.apache.spark.sql.expressions.Aggregator import org.apache.spark.sql.expressions.Aggregator scala> class SumOf[I, N : Numeric](f: I => N) extends Aggregator[I, N, N] with Serializable { | val numeric = implicitly[Numeric[N]] | override def zero: N = numeric.zero | override def reduce(b: N, a: I): N = numeric.plus(b, f(a)) | override def merge(b1: N,b2: N): N = numeric.plus(b1, b2) | override def finish(reduction: N): N = reduction | } <console>:10: error: not found: type Aggregator class SumOf[I, N : Numeric](f: I => N) extends Aggregator[I, N, N] with Serializable { ^
Attachments
Issue Links
- is related to
-
SPARK-14642 import org.apache.spark.sql.expressions._ breaks udf under functions
- Resolved