我想使用apache flink实时分析事件流，并基于以下内容触发操作：
事件窗口，其中发生特定事件（“如果事件a和事件b在30秒内发生->触发操作”）
发生特定事件的事件序列（“如果事件a发生在事件b之后，而事件c发生在事件b之后->触发动作”）
两者的结合
我知道Flink有能力通过 stream.windowAll(...) 但我不确定如何反映事件的顺序。
如何实现这样的事件序列检测？
我想使用apache flink实时分析事件流，并基于以下内容触发操作：
事件窗口，其中发生特定事件（“如果事件a和事件b在30秒内发生->触发操作”）
发生特定事件的事件序列（“如果事件a发生在事件b之后，而事件c发生在事件b之后->触发动作”）
两者的结合
我知道Flink有能力通过 stream.windowAll(...) 但我不确定如何反映事件的顺序。
如何实现这样的事件序列检测？
1条答案
按热度按时间xyhw6mcr1#
Flink塞普(https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html)是一个cep（complex event processing）库，能够以更抽象的方式处理事件流，并且（除其他外）涵盖了您所描述的场景。