問題タブ [esper]

メソッドの 1 つが特定の値を返すオブジェクトの特定のクラスを取得するために Esper を使用しています (または使用しようとしています)。これが私が今設定しているステートメントです。

以下を実行すると、フィルタリングがないことを除いて、すべてが正常に機能するため、他のすべてが機能することを知っています。

このステートメントは、具体的には「test.getObject()」でスローされます。

ありがとう！

私のイベント ストリームには通常、open イベントとそれに続く close イベントが含まれます。Oそれらを と と呼びましょうC。ただし、2 つの詳細があります。

1. O到着するO前に1つ以上が続く場合がありますC
2. C完全に欠落している可能性があります（以下を参照）

遅くとも時間内にC到着するはずです。それ以外の場合は、行方不明と見なされます。最終的に が到着すると、それよりも前に到着したすべてのopenは孤立していると見なされ、関心がなくなります。TOCCOTC

esperにの各ペアを発射さOせたいと思っています。間および選択前のはスキップされます。COTCOO

例えば、

O1 O2 O3 ... C

(O1,C)場合に選択する必要がありますdatediff(O1, C) < T

(O2,C)上記がfalseの場合は選択する必要があり、datediff(O2, C) < T

等

A は、この問題に取り組むことに腹を立てました。私の心はエスパーと互換性がないようです。あなたの助けは非常に感謝しています。

私はESPERを初めて使用します。SQLのようなクエリをチェックしていました。これが私のシナリオです。お気に入りのユースケースを処理する必要があります。1 つの推奨エンジンがあり、12 時間ごとにいくつかの URL をユーザーに推奨します。ユーザーが URL をお気に入りとしてマークするかどうかのいずれかで操作すると、イベントは ESPER に送られます。

1. ユーザーが URL をお気に入りとしてマークした場合、CEP はレコメンデーション エンジンに同じ URL を再度送信しないように指示する必要があります。
2. ユーザーが n 回推奨された後に URL をマークしない場合 (ユーザーが興味を示さない場合)、CEP はレコメンデーション エンジンに同じ URL を再度送信しないように指示します。

進め方を教えてください。Favorite Event を POJO として使おうと思っています。

他のいくつかのシステムに接続し、イベントをストリームにプッシュするアプリケーションがあります。各コネクタは、ステータスの変化に応じてステータス メッセージも送信します。ステータスが少し前に送信された場合でも、各コネクタに送信された最後のステータスを表示する esper クエリが必要です。私たちの豆はこのように見えます

次の esper クエリを試しましたが、名前ごとに最初のステータス メッセージしか返されないようです。

エスパー初心者です。私は通常のタイム ウィンドウ クエリは苦手ではありませんが、最後のイベントを長時間保持するのは困惑しています。コネクタは数十個しかなく、ステータスが何時間も変わらない可能性がありますが、最後に送信されたステータスを引き続き確認したいと考えています。

それぞれが次のプロパティを持つ一連のイベントがあります。

さらに、EPL と Esper でモデル化したい一連の階層またはネストされたルールがあります。各ルールは、そのすべての親ルールがすでにアクティブになっている場合にのみ適用する必要があります (それらすべてに対して一致するインスタンスが発生しました)。例えば：

このルール階層の各レベルに対応するすべてのイベント インスタンスを取得します。たとえば、次のイベントを考えてみます。

ルール階層で、階層の各レベルに対応するすべてのイベントの ID とともにこのインスタンスを報告する必要があります。たとえば、次のようなレポートが必要です。

Esper EPL でこれを達成する (すべてのルールに一致するイベントの ID を取得する) にはどうすればよいでしょうか?

すべてのイベントを保持し、必要に応じて StreamInsight でイベントを追加または削除する方法はありますか? Esper には、ウィンドウに適用できる keepall() というメソッドがあります。このメソッドはすべての着信イベントを保持し、ウィンドウにイベントを挿入したり削除したりするためのさまざまなクエリを使用できます。

HoppingStreamInsight で、Snaphot、Tumblingおよびを使用してみCount Windowましたが、上記の機能はありません。

ありがとう。