私はStreamExecutionEnvironment.readFileメソッドを理解していません。 FileProcessingModeには、PROCESS_ONCEとPROCESS_CONTINUOUSLYという2つのオプションがあります。前者を選択すると、ファイルを一度だけ処理し、execute()の後に終了します。後者を選択すると、ファイルにいくつかの行を追加するだけで、ファイル全体を再度処理します(最後の処理の上に各単語の数など)。私はそれが「尾」のようなものだと思っています。何度も何度も何度も読んでいるのではなく、「ストリーム」からもっと多くのものを読むだけです。私はこの "ストリーミング"を失いました。誰かが、「一度」だけファイルを処理し、ファイルがログファイルのように多くのテキストを添付している間に続けるという「テール」のようなものがない理由を説明できますか?Flink FileProcessingMode困惑
0
A
答えて
0
PROCESS_CONTINUOUSLYでは、Flinkはタイムスタンプを状態として保持し、タイムスタンプより新しいファイルを取り込みます。あなたの観察は正確ですが、これがうまくいく場合があります。ファイルではなくディレクトリでPROCESS_CONTINUOUSLYを使用し、処理が完了し準備が整ったときに定期的にファイルをそのディレクトリに移動すると、「正確に1回」の動作が得られます。
関連する問題
- 1. SQLの困惑スーパーセット
- 2. K&Rエクササイズで困惑1.5.2
- 3. スカラ並列コレクションランタイム困惑
- 4. 奇妙なwhileループ。困惑
- 5. ASP.NET MVCアプリケーションの困惑動作
- 6. 困惑の問題を解決する
- 7. 困惑辞書一致問題
- 8. ユーザーコントロールのカスタムプロパティで困惑しました
- 9. FileNotFound例外で困惑しました
- 10. エラー1064(42000)作成テーブルで困惑しました
- 11. Cのループについて困惑しました
- 12. Torch CmdLine:テキストの動作が困惑しています
- 13. .htaccessで完全に困惑しました
- 14. エンティティフレームワークとラムダ式に困惑しました
- 15. 私は困惑 - 厳しい基準を:変数のみが
- 16. 困惑線形回帰によって結果
- 17. シンプルなCSS継承で困惑しました
- 18. Haskellで困惑しているメモリの動作
- 19. Sassのmixinsと$ variablesに困惑しました
- 20. REST:私はこれらの2と困惑しているAPI
- 21. 春データJPAは:全く困惑外部キー
- 22. これは私が困惑している
- 23. linux smc91cxドライバコードと関連するデータシートに困惑?
- 24. 私はこの例では困惑している
- 25. フォームクローズイベントで私は困惑しています
- 26. 私が困惑した基本的なポインタ算術
- 27. ジキル・リキッド・エラーが私を困惑させている
- 28. "facet_grid"とオーバープロット:困惑している行動
- 29. JSコードは、配列は私が困惑している
- 30. 同期ロックを使用すると困惑します