火石中 spark的等效RDD


0

在apachespark中,很多时候我们使用RDD forEach来计算或处理RDD中的每个数据……我想知道Apache Flink中的相同值是什么??

2 答案


0

在 Flink没有对等物。但是,您可以使用map()并将自定义函数放入其中。

只是想澄清一下:

    RDD是一个Spark概念——Flink在数据流上 job 。

0

由于1.2版Flink提供了ProcessFunction,它或多或少类似于Spark中的forEach,因为它是为每个流元素调用的。


我来回答

写文章

提问题

面试题