scala - スパークストリーミングでは、foreachとforeachRDDの違いは何ですか?

Question

たとえば、どのように

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

とは異なる

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

ここにあることに注意しxてDStreamください。

Answer 1

作業に違いはなく、 foreach()はforeachRDD を使用しています。foreach() は廃止され、Spark 2.0 ではこの関数は削除されました