Flink CEP - таймаут и паттерны Dynami c - PullRequest
0 голосов
/ 31 марта 2020

Есть ли способ достичь следующего с помощью Flink CEP

  1. Продолжить сопоставление всех событий, которые не поступили в течение времени. Например, A -> B -> C должны совпадать в течение 20 секунд, и прибыло только событие A, сейчас я вижу, что тайм-аут наступает через 20 секунд. После тайм-аута, если приходит B, шаблон не совпадает. Как мы можем убедиться, что он продолжает совпадать после истечения времени ожидания.

  2. Несколько тайм-аутов - можно ли несколько раз предупреждать о данном паттерне. У меня есть случай, когда мне нужно предупредить в моменты времени t1, t2, t3. Есть ли способ достичь этого?

  3. Множественные паттерны - были ли некоторые статьи, где NFACompiler.NFAFactory поддерживается на карте и на основе данных, ищется правильный и используемый. Есть ли пример, который я могу найти, как это сделать с текущей версией Flink.

...