scala - 在火花流中，foreach和foreachRDD有什么区别

Question

例如，将如何

x.foreach(rdd => rdd.cache())

不同于

x.foreachRDD(rdd => rdd.cache())

注意这里x是a DStream。

Answer 1

工作上没有区别，foreach()使用foreachRDD。foreach() 已被弃用，在 Spark 2.0 中此函数已被删除