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
с в DataStream
s, объедините их с помощью объединения и запустите новую последовательность шаблонов в объединенном потоке. "Одна большая" последовательность паттернов невозможна, поскольку в каждой последовательности есть разные временные окна.
Спасибо за помощь.