检测某个事件的缺失

Question

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

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

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

提前致谢， 温贝托

Answer 1

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

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

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