检测某个事件的缺失

Question

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

然而，我想知道我是否能在时间X之后检测到某个事件的缺失。例如，如果一个事件A在10秒内没有跟随另一个事件A，则发出警报或采取措施。

可以定义FlinkCEP模式来捕捉这种情况吗？

提前感谢，Humberto

Answer 1

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

Flink培训包括一项练习，目的是识别在两小时内有START事件而没有END事件的出租车骑行。您将找到使用CEP的此练习的解决方案在这里

主要想法是在10秒内定义一个a后面跟着a的模式，然后捕捉这个超时的情况。