相当のRDD ForEach of Flark Flickの

Question

Apache Sparkでは、RDD forEachを使用してRDDで各データを評価または処理することが何度もあります... Apache Flinkで同じものが何であるか知りたいですか？

Answer 1

Flinkには同等のものはありません。ただし、map()を使用してそこにカスタム関数を置くことができます。ただ、明確にする

：

1. RDDSは、Spark概念です - FLINKは、データストリーム上の作業を行います。すなわち、地図のUDFは何のforEach UDFを行う必要があります -
2. forEachは、このように、FLINKでmap()を使用して、あなたは「副作用との同一機能」配置する必要があります（各要素に対して関数を呼び出しますが、基礎となるデータは変更されません。 、プラス未修飾の入力レコードを発するない。）

Answer 2

バージョン1.2 FLINKためすると、各ストリーム要素に対して呼び出されることで、スパークにforEachに多かれ少なかれ類似であるProcessFunctionを提供します。