在spark streaming中,foreach和foreachRDD有什么区别
In spark streaming, what is the difference between foreach and foreachRDD
例如,
x.foreach(rdd => rdd.cache())
不同于
x.foreachRDD(rdd => rdd.cache())
注意这里的x
是DStream
。
工作没有区别,foreach() uses foreachRDD。 foreach() 已弃用,在 Spark 2.0 中此函数已删除
例如,
x.foreach(rdd => rdd.cache())
不同于
x.foreachRDD(rdd => rdd.cache())
注意这里的x
是DStream
。
工作没有区别,foreach() uses foreachRDD。 foreach() 已弃用,在 Spark 2.0 中此函数已删除