2017-09-07 60 views
0

我有esper processer配置爲在kafka中偵聽郵件。如何在給定的時間內沒有傳入事件觸發esper

通常select * from events.win:time(2 min)將觸發最近2分鐘內的所有事件 現在,如果最後2分鐘沒有卡夫卡消息,我想觸發通知。

我應該怎麼處理它,當我喜歡寫東西 select * from events(Ip='1.1.1.1').win:time(2 min) 這不會有匹配的郵件/事件和超能力者不觸發。

我應該如何觸發超能力者,如果事件在給定的時間沒有提前

感謝

回答

1

你能做到這一點

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

//提示:不要叫你的事件「事件「,叫它有用的,並使用大寫

+0

謝謝!我一天後想到了這一點,你回答的是完全正確的。早些時候,我嘗試了'select count(*)from myEvents.win:time(1 min)'1> count(*)'這不起作用 - 最後我遇到了上述解決方案。 –

+0

在我的實際代碼中,這不是事件,我認爲社區成員可以很容易理解我的問題,所以我使用'events'。感謝指出它 –