イベントの順序が

Question

CEPライブラリはXが

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

Y.が続いている場合、それは簡単なことを伝えることができます記述するためにプログラムを書くことができます重要ではありませんFLINK CEPプログラムを作成する方法しかし、私はどのように私はXとYの順番に気にしないプログラムを記述するのだろうか？例えばX、YおよびY、Xはいずれも興味深い。しかし、X、XまたはY、Yは興味深いものではないので、3番目の共有プロパティで一致することはできません。

Answer 1

現在のところ、この機能はFlinkのCEPライブラリではサポートされていません。これらの2つのパターンを別々に定義し、select節の後に結果として生じる両方のデータストリームを結合することができます。