Как написать программу Flink КЭП, где порядок событий не имеет значения

Question

Библиотека СЕР позволяет легко написать программу, чтобы описать, что можно сказать, если 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

В настоящий момент эта функция не поддерживается в библиотеке CEP от Flink. Что вы можете сделать, так это определить эти два шаблона отдельно, а затем объединить оба результирующих потока данных после предложения select.