更新时间:2023-11-18 22:21:46
尝试
topCounts60.foreachRDD { rdd => for ((k,v) <- rdd.collect) printf("key: %s, value: %s\n", k, v) }
Scala/Spark中的异常org.apache.spark.rdd.RDD [(scala.collection.immutable.Map [String,Any],Int)]