我试图总结所有基于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(_+_)
有人可以帮我解决这个问题吗?