0
下面的代碼用於查找值的平均值。我不確定爲什麼在平均函數中使用隱式num:Numeric [T]參數。在火花中使用隱式參數
代碼:
val data = List(("32540b03",-0.00699), ("a93dec11",0.00624),
("32cc6532",0.02337) , ("32540b03",0.256023),
("32cc6532",-0.03591),("32cc6532",-0.03591))
val rdd = sc.parallelize(data.toSeq).groupByKey().sortByKey()
def average[T](ts: Iterable[T])**(implicit num: Numeric[T])** = {
num.toDouble(ts.sum)/ts.size
}
val avgs = rdd.map(x => (x._1, average(x._2)))
請幫忙知道使用(隱NUM:數字[T])的原因參數。