Apache Flink: объединение шаблонов CEP

Есть ли способ объединить шаблоны CEP?

Пример:

Pattern s1 = Pattern
  .begin("s1_start").where(startcondition1)
  .followedBy("s1_end").where(endcondition1) )

Pattern s2 = Pattern
  .begin("s2_start").where(startcondition2)
  .followedBy("s2_end").where(endcondition2) )

Теперь я хочу объединить эти два шаблона с условием AND: s1 AND s2

В настоящее время я конвертирую полученный PatternStreamс в DataStreams, объедините их с помощью объединения и запустите новую последовательность шаблонов в объединенном потоке. "Одна большая" последовательность паттернов невозможна, поскольку в каждой последовательности есть разные временные окна.

Спасибо за помощь.

0 ответов

Другие вопросы по тегам