はカフカ mapWithState/updateStateByKeyはキャッシュされていますか?
- を持っている、のと仮定しましょう状態を保存するためにいくつかの変換
- 使用
mapWithState
/updateStateByKey
を行います。 - ストリームを状態からさらに変換します。
- いくつかのアクション1とアクション2を実行します。
注:まだキャッシュを使用していません。
私の質問は、ステップ2の変換が(アクション1とアクション2ごとに1回)2回実行されますが、
- のですか?私のために、それは一度だけ実行されているようだ!
mapWithState
/updateStateByKey
返信dStream
、自動的にキャッシング/保存を行うのですか?- 保証はありますか?
mapWithState
/updateStateByKey
の前の変換は一度だけ適用され、再計算されませんか? 30日前に取得したデータがまだ状態に含まれている場合は、事前計算された結果が見つからない場合は再計算されますか?