mapWithState（）。一部の関数をトリガーするtimeout（）

Question

mapWithState().timeout()関数をイベントとして使用して、他の関数をトリガーしたいと考えています。そうする方法はありますか？

statesnapshot()については、timeoutログメッセージを検索しましたが、これについて十分な情報が見つかりませんでした。私の問題に対する何らかの答えが始まるだろうか？これについてもっと知る場所はどこですか？

Answer 1

という機能をmapWithState().timeout()というイベントとして使用して、他の機能を起動したいと考えています。方法はありますか？

はい、可能です。あなたができることは、タイムアウトが発生したときに呼び出されるアクションを定義することです。 MapWithStateRDDでタイムアウトが発生したことをどのように知っていますか？ State[S].isTimingOut()メソッドを見ることができます。タイムアウトの期限が切れた後、この方法では、trueが得られるとmapWithStateはvalueがNoneに設定された状態でStateSpec方法1つの最後の時間を実行します：

object Foo { 
    def main(args: Array[String]): Unit = { 
    val spec = StateSpec.function(updateState _).timeout(Milliseconds(5)) 
    // Use spec to invoke `mapWithState` 
    } 

    def updateState(key: Int, value: Option[Int], state: State[Int]): Option[Int] = { 
    value match { 
     case Some(number) => Some(number + 1) 
     case _ if state.isTimingOut() => // Trigger Code Here 
    } 
}