Flink的基于ValueState的状态机
生活随笔
收集整理的這篇文章主要介紹了
Flink的基于ValueState的状态机
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
最近瀏覽ververica[1]的時(shí)候,看到了這么個(gè)例子[3]
首先復(fù)習(xí)下數(shù)字電路里面狀態(tài)機(jī)的概念
Qn+1=F(Qn)Q_{n+1}=F(Q_{n})Qn+1?=F(Qn?)
[3]這個(gè)例子只是在用ValueState來(lái)解釋Flink的State管理,
并且還在[2]中提到
While this example is much simpler and more manual than what the CEP library supports, it illustrates the use of event processing and state management for a medium complex scenario.
所以本文結(jié)論:
關(guān)于ValueState這個(gè)狀態(tài)機(jī),雖然在Ververica的ppt中出現(xiàn),
但是在應(yīng)用上沒(méi)有任何價(jià)值,不需要學(xué)習(xí).
Reference:
[1]狀態(tài)管理與容錯(cuò)機(jī)制
[2]例子說(shuō)明
[3]StateMachineExample.java
總結(jié)
以上是生活随笔為你收集整理的Flink的基于ValueState的状态机的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: The configured Task
- 下一篇: 王者荣耀ag超玩会为什么退出kpl 最新