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