apache-flink - 如何编写一个事件顺序无关紧要的 Flink CEP 程序

Question

CEP 库使得编写一个程序来描述它可以很容易地判断 X 是否跟在 Y 后面。

val pattern = Pattern.begin("start").where(_.value == "X") .next("end).where(_.value == "Y")

但是我将如何描述一个我不关心 X 和 Y 的顺序的程序，只关心一个跟随另一个的顺序。例如 X, Y 和 Y, X 都很有趣。但是，X,X 或 Y,Y 并不有趣，所以我无法匹配第三个共享属性。

Answer 1

目前，Flink 的 CEP 库不支持该功能。您可以做的是分别定义这两种模式，然后在 select 子句之后合并两个结果数据流。