Apache Sparkでは、RDD forEachを使用してRDDで各データを評価または処理することが何度もあります... Apache Flinkで同じものが何であるか知りたいですか?相当のRDD ForEach of Flark Flickの
1
A
答えて
0
Flinkには同等のものはありません。ただし、map()
を使用してそこにカスタム関数を置くことができます。ただ、明確にする
:
- RDDSは、Spark概念です - FLINKは、データストリーム上の作業を行います。すなわち、地図のUDFは何のforEach UDFを行う必要があります -
forEach
は、このように、FLINKでmap()
を使用して、あなたは「副作用との同一機能」配置する必要があります(各要素に対して関数を呼び出しますが、基礎となるデータは変更されません。 、プラス未修飾の入力レコードを発するない。)
0
バージョン1.2 FLINKためすると、各ストリーム要素に対して呼び出されることで、スパークにforEach
に多かれ少なかれ類似であるProcessFunction
を提供します。
関連する問題
- 1. Python foreach相当語
- 2. jqueryでforeach相当のphp?
- 3. クエリのためのSQLのforeach相当
- 4. jQuery UI loading flick
- 5. RDDとペアRDDの相違点と使用例
- 6. RDDでForeachが動作しない
- 7. Try of List要素のRDDに対する包括性
- 8. のGradle相当
- 9. IsFinite()相当の
- 10. 相当のスコープ?
- 11. のGradle相当
- 12. PowershellのC#相当コード
- 13. リターンファイル相当
- 14. xml相当のjson_decode関数
- 15. WindowsフォームUserControl + Panel:WPF相当の
- 16. 相当
- 17. OCaml相当のタイプ
- 18. パブリックメソッドの__call相当
- 19. Golang requirements.txt相当の
- 20. wxWidgets PostNcDestroy相当の
- 21. ieee_exceptionsのGFortran相当
- 22. フレット相当のlet *?
- 23. XkbSetDetectableAutoRepeatのXCB相当
- 24. ART相当のdvmDumpAllThreads
- 25. CDC DrawDragRect相当の
- 26. propel相当の "exists"
- 27. tensorflow theano.tensor.set_subtensor相当の
- 28. erlangのpstack相当
- 29. Jframe相当のjavascript
- 30. angular2相当のangular.isArray