关于DStream的foreach操作

 foreachRDD的作用是把DStream转换为rdd,真正的foreach是rdd.foreach,这里是要用rdd的foreachpartition算子,可以提高性能。

DStream的tranform可以在内部使用RDD的算子,并且不会立即执行,因为其不是action算子。

原文地址:https://www.cnblogs.com/sunpengblog/p/11740727.html