Spark StreamingでupdateStateByKey（）のようにmapWithState（）を使用できますか？

Question

私はupdateStateByKey（）の代わりにmapWithState（）関数を使用して初期状態を読み込み、タイムアウトを使用しています。しかし、特定のキーの新しい値が消費されたかどうかに関係なく、状態ストア全体を更新する必要があります。

これを行う方法はありますか？

Answer 1

いいえ、できません。 hereのように、性質がmapWithStateであるため、状態ストア全体を更新することはできません。