java - 如果给定时间段内没有传入事件，如何触发 esper

Question

我配置了 esper 处理器来监听 kafka 中的消息。

通常select * from events.win:time(2 min)会触发最后2分钟内的所有事件现在，如果过去 2 分钟 kafka 中没有消息，我想触发通知。

当我写这样的东西时，我应该如何处理它 从事件中选择*(Ip='1.1.1.1').win:时间(2分钟) 这不会有匹配的消息/事件，并且 esper 不会触发。

如果给定时间内事件不存在，我该如何触发esper

提前致谢

Answer 1

你可以这样做

select * from pattern [every (timer:interval(2 min) and not MyEvent)]

//提示:不要将您的事件称为“事件”，而是使用有用的名称并使用大写