小编G3M*_*G3M的帖子

假设我有一个文件,每行代表一个数字.如何在Scala - Spark中找到文件中所有数字的平均值.

val data = sc.textFile("../../numbers.txt")
val sum = data.reduce( (x,y) => x+y )
val avg = sum/data.count()

这里的问题是x和y是字符串.如何在reduce函数中将它们转换为Long.