Одновременно существует один шаблон FLINK CEP

Возможно ли иметь один шаблон для ключа за раз. Например, Я хочу проверить, получаю ли я 5 событий, которые соответствуют условию where в течение 1 минуты, и если я получаю 10 таких событий за минуту, я должен получить 2 предупреждения, но я получаю 6 предупреждений. Это потому, что каждое событие запускает новый паттерн. Можем ли мы иметь по одному экземпляру шаблона для ключа.


person Anand Shaw    schedule 04.12.2017    source источник


Ответы (1)


Похоже, у вас похожая проблема, которая была у меня: я не хочу, чтобы одно и то же событие участвовало более чем в одном скользящем окне. Я смог добиться этого с помощью AfterMatchSkipStrategy.skipPastLastEvent (). Это доступно в версии 1.4. Надеюсь это поможет!

person sshum    schedule 05.12.2017
comment
Спасибо @sshun. Это то, что я хотел. - person Anand Shaw; 05.12.2017