Flinkの状態バックエンドへの時間枠の集計結果を保存します

Question

私はApache Flink（1日:)に新しく、状態を保存するガイドはほとんどありません。 by documentation, you can use:

FsStateBackend

をmemoryStateBacked

• RocksDBStateBackend

それにもかかわらず、私は、この状態のバックエンドへの書き込み/読み込みのサンプルコードを見つけることができませんでした。

これはFlinkの内部使用のためのものであることを意味しますか、それとも私も使用できますか？

意味：最終日の集計を保存し、Flinkをリセットしてから再度キャッシュを読み取ることはできますか？ （例えばRedisの場合と同じように）

Answer 1

オペレータの現在の状態を保存するために使用されます。

まだ見ていない場合は、例と詳しい説明があります。here

基本的に、状態がpublic void open(Configuration config)機能

で定義され、その後、flatMap機能であなたがmystate.value()を呼び出して状態にアクセスすることができますし、また、現在、これは何をすることができますですmystate.update(newvalue)

を使用して更新することができます州とは関係がありますが、QueryableStateという新機能があります。FLINK-3779があり、Flinkの状態をFlink外に照会することができます。

PS：私はRedisがどのように状態を処理しているのか分かりません