- 1.美图
- 2.NFA
- 3.源码
NAF-非确定有限状态机
FlinkCEP在运行时会将用户的逻辑转化成这样的一个NFA Graph (nfa对象)
graph 中包含状态(Flink中State对象),以及连接状态的边(Flink中StateTransition对象)
当从一个State跳变到另一个State时需要通过一条边StateTransition,这条边中包含一个Condition对象包含了用户的逻辑就是我们用户代码中.where()中返回Boolean的

NAF-非确定有限状态机
FlinkCEP在运行时会将用户的逻辑转化成这样的一个NFA Graph (nfa对象)
graph 中包含状态(Flink中State对象),以及连接状态的边(Flink中StateTransition对象)
当从一个State跳变到另一个State时需要通过一条边StateTransition,这条边中包含一个Condition对象包含了用户的逻辑就是我们用户代码中.where()中返回Boolean的