3
例如之间的差别,怎么会在火花流,是什么的foreach和foreachRDD
x.foreach(rdd => rdd.cache())
是不同
x.foreachRDD(rdd => rdd.cache())
注意x
是这里的DStream
。
例如之间的差别,怎么会在火花流,是什么的foreach和foreachRDD
x.foreach(rdd => rdd.cache())
是不同
x.foreachRDD(rdd => rdd.cache())
注意x
是这里的DStream
。
工作没有什么区别,foreach()uses foreachRDD。 foreach()已弃用,并且在Spark 2.0中删除了此功能