Apache Flink: условия в шаблонах CEP

Я новичок в Apache Flink и в библиотеке CEP. У меня есть два (или более) шаблона, которые используют данные из разных источников. Если два шаблона имеют совпадающие события, я хочу отправить и предупредить, но порядок соответствия не имеет значения, то есть я хочу, чтобы сигнал тревоги отправлялся только тогда, когда оба шаблона совпадают, независимо от того, следовал ли сначала один, а затем другой. Что-то вроде "И операция" между шаблонами. Я провел небольшое исследование и нашел только одну операцию "ИЛИ". В коде APache Flink есть класс AndCondition.java, но он, похоже, не использует его так же, как OrCondition.java ... есть ли решение Flink для этого случая? Пользователь задал этот вопрос несколько месяцев назад Apache Flink: объединение шаблонов CEP

И я с той же проблемой, но никто не ответил на этот вопрос... Спасибо за помощь и терпение!

0 ответов

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