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)
這不會有匹配的郵件/事件和超能力者不觸發。
我應該如何觸發超能力者,如果事件在給定的時間沒有提前
感謝
謝謝!我一天後想到了這一點,你回答的是完全正確的。早些時候,我嘗試了'select count(*)from myEvents.win:time(1 min)'1> count(*)'這不起作用 - 最後我遇到了上述解決方案。 –
在我的實際代碼中,這不是事件,我認爲社區成員可以很容易理解我的問題,所以我使用'events'。感謝指出它 –