rdd的火花缩放中的ReduceByKey不起作用

我试图总结所有基于StudentId的分数。我用过reduceByKey。但这引发了错误。 有人可以帮我解决此问题。

scala> studentPairRDD.foreach(println)

Id,subject,marks,class

(3,social,40,10)

(4,maths,45,science,30,9)

(1,90,8)

(1,80,10)

(2,100,8)

(2,9)

(2,10)

(3,35,9)

(3,36,8)

(4,42,8)

(5,20,9)

(5,10)

基于上述结果,我将reducebyKey应用于了StudentId的总和。 但这是错误

val totalmarksRDD = studentPairRDD.reduceByKey(_+_)

<console>:31: error: value reduceByKey is not a member of 

org.apache.spark.rdd.RDD[(String,String,Double)]

val totalmarksRDD = studentPairRDD.reduceByKey(_+_)

有人可以帮我解决这个问题吗?

leqihuan 回答:rdd的火花缩放中的ReduceByKey不起作用

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3129222.html

大家都在问