0
아래 코드는 평균 값을 찾는 데 사용됩니다. 암시 적 num : 평균 함수에 숫자 [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])를 사용하는 이유를 알고 도와주세요 매개 변수를.