问星火DStream.transform().foreachRDD() vs DStream.foreachRDD()
EN

Stack Overflow用户

提问于 2017-03-28 18:15:40

回答 1查看 798关注 0票数 2

因此，我想知道，首先在直接流上应用转换，然后调用foreachRDD，而不是只执行后者，是否会有显著的区别。

发布于 2017-06-14 13:24:49

区别在于调用transform()时所做的转换。在transform(func).中，transform接受一个函数：transform根据func的实现，结果会有所不同。

简化DAG的术语：

DStream.transform().foreachRDD()是Transformation -> Action

DStream.foreachRDD()只是一个Action

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/43077004

复制

相似问题

问星火DStream.transform().foreachRDD() vs DStream.foreachRDD()EN