apache-flink - 检测某个事件的缺失

Question

notFollowedBy在 FlinkCEP 的文档中，我发现我可以使用or强制在其他两个事件之间不发生特定事件notNext。

但是，我想知道是否可以在时间 X 之后检测到某个事件的缺失。例如，如果一个事件A在 10 秒内没有跟随另一个事件A，则触发警报或执行某些操作。

是否可以定义一个 FlinkCEP 模式来捕捉这种情况？

在此先感谢，温贝托

标签： apache-flinkflink-cep

Answer 1

尽管 Flink CEP 不支持 Pattern 末尾的 notFollowedBy，但有一种方法可以通过利用超时功能来实现这一点。

Flink 培训包括一个练习，其目标是识别在两小时内没有跟随 END 事件的 START 事件的出租车行程。您将在此处找到使用 CEP 的本练习的解决方案 。

主要思想是在 10 秒内定义 A 的模式，然后是 A，然后捕获超时的情况。