【发布时间】:2017-08-07 04:15:09
【问题描述】:
我想使用 Apache Flink 实时分析事件流并根据以下条件触发操作:
- 事件窗口,发生特定事件(“如果事件 A 和事件 B 在 30 秒内发生 -> 触发动作”)
- 事件序列,其中发生了特定事件(“如果事件 A 发生在事件 B 之后,事件 C 发生在事件 B 之后 -> 触发动作”)
- 两者的结合
我知道 flink 能够通过 stream.windowAll(...) 进行窗口化,但我不确定如何反映事件序列。
如何实现这样的事件序列检测?
【问题讨论】:
标签: events real-time apache-flink flink-streaming