Обнаружить отсутствие определенного события

Question

В документации FlinkCEP я обнаружил, что могу обеспечить, чтобы между двумя другими событиями не возникало определенного события, используя notFollowedBy или notNext.

Однако мне было интересно, смогу ли я обнаружить отсутствие определенного события по истечении времени X. Например, если за событием A не последовало другое событие A в течение 10 секунд, активировать оповещение или сделать что-то еще.

Можно ли определить шаблон FlinkCEP для захвата этой ситуации?

Заранее спасибо, Умберто

Answer 1

Хотя Flink CEP не поддерживает notFollowedBy в конце шаблона, существует способ реализовать это, используя функцию тайм-аута.

Тренировка Flink включает упражнение , целью которого является идентификация поездок на такси с событием START, за которым не следует событие END в течение двух часов. Вы найдете решение для этого упражнения, в котором используется CEP здесь .

Основная идея состоит в том, чтобы определить шаблон A с последующим A в течение 10 секунд, а затем зафиксировать случай, когда на этот раз.