如何寫一個弗林克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子句後合併兩個結果數據流。