火石中 spark的等效RDD

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

只是想澄清一下：

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

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