2017-09-07 6 views
0

私はkafkaのメッセージを聴くようにエスペルプロセッサーを設定しています。与えられた期間に着信イベントがない場合にエスパーをトリガーする方法

通常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

ありがとうございました!私はこの日を思い出しました。以前は実際に私は '> count(*)'を持つmyEvents.win:time(1分)からselect count(*)のようなものを試してみましたが、うまくいきませんでした。 –

+0

私の実際のコードではイベントではないので、コミュニティメンバーが自分の質問を理解するのは簡単かもしれないと思ったので、私はそのイベントを使いました。指してくれてありがとう –

関連する問題