当我在Spark Terminal上运行它时,下面的代码工作正常,但在eclipse中它会抛出错误.可能是什么原因.如果您需要更多信息,请与我们联系.
val IABLabels = IAB.zip(labels)
val temp1 = IABLabels.groupBy(x => x._2).mapValues(_. map(_._ 1))
Eclipse中的错误:
value mapValues不是org.apache.spark.rdd.RDD [(Int,Iterable [(String,Int)])]的成员
代码在Spark shell上运行得非常好.