如何使用 Apache Flink 分析事件序列来触发动作?

Question

我想使用 Apache Flink 实时分析事件流，并根据以下条件触发操作：

• 发生特定事件的事件窗口("如果事件 A 和事件 B 在 30 秒内发生 ->触发操作"(
• 发生特定事件的事件序列("如果事件 A 发生在事件 B 之后，事件 C 发生在事件 B 之后 -> 触发操作"(
• 两者的组合

我知道 flink 能够通过stream.windowAll(...)窗口化，但我不确定如何反映事件序列。

如何实现此类事件序列检测？

Answer 1

FlinkCEP(https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html(是一个CEP(复杂事件处理(库，能够以更抽象的方式处理事件流，并且(除其他外(涵盖了您所描述的场景。