0
私はkafkaのメッセージを聴くようにエスペルプロセッサーを設定しています。与えられた期間に着信イベントがない場合にエスパーをトリガーする方法
通常select * from events.win:time(2 min)
最後の2分間にすべてのイベントが発生します 最後の2分間はカフカにメッセージがない場合に通知を開始します。
select * from events(Ip='1.1.1.1').win:time(2 min)
このようなメッセージやイベントはありません。エスパーはトリガーしません。あなたのイベント「のイベントを呼び出すことはありません:イベントが与えられた時間内に事前
ありがとうございました!私はこの日を思い出しました。以前は実際に私は '> count(*)'を持つmyEvents.win:time(1分)からselect count(*)のようなものを試してみましたが、うまくいきませんでした。 –
私の実際のコードではイベントではないので、コミュニティメンバーが自分の質問を理解するのは簡単かもしれないと思ったので、私はそのイベントを使いました。指してくれてありがとう –