問題タブ [esper]

フィールドの値が 2 つのウィンドウの値に依存する select ステートメントを使用しようとしています。また、最後に where ステートメントを使用して、1 つのウィンドウからイベントを除外します。例えば。

問題は、一致がない場合でもイベントを出力したいということです。そのため、B ストリームは null として扱われます。

Java で Mongo と Esper を使用しています。esper サーバーを起動したら、ドキュメントの追加を開始し、リスナーの 1 つで、それらのドキュメントの一部を更新する必要があります (1 回につき 1 つ)。問題は、Mongo がこれらのドキュメントを更新するのは、サーバーを起動する前にドキュメントがデータベースにあった場合のみであり、ドキュメントを挿入したばかりの場合は更新しないことです。

私はこのコードを実行しています：

何が起こっているのか、誰にも手がかりがありますか？他に必要な情報がある場合は、お知らせください。

どうもありがとうございました。

問題は非常に単純です。Esper エンジンを使用して、2 つの異なるストリームから存在しないレコードのみを抽出します。
ID は streamA に存在しますが、streamB には存在しません。

SQL では、次のようになります。

Esper スタイルで試してみましたが、うまくいきません:

残念ながら、stream_A.Id が stream_B.id の前に挿入された場合、それはクエリ条件に応答し、クエリは機能しません。

Esperを使用して「IDはstreamAに存在するが、streamBには存在しない」を識別する方法に関する提案はありますか?

以下は、当社の Esper EPL ステートメントです。

上記の EPL のように配列値を 1 つだけ取得するのではなく、上記のクエリですべての配列要素 (上記の「inputCounts」で配列サイズを指定) を反復処理するにはどうすればよいでしょうか。

これに関するヘルプは大歓迎です!!

サンニット。

esper でデータ処理時間を記録したいので、例としてボリンジャー バンドを選択します。ボリンジャーバンドには、移動平均線（MA）と呼ばれるものがあります。株価平均を計算した結果から得られたMA。この場合、win:length(20) を設定します。したがって、MA は、データ ウィンドウ ビューに存在する 20 のイベントから株価平均を計算した結果から取得できます。以下は私が作成したコードです。

上記のコードから、平均が計算された場合に時間が記録されます。しかし、私が必要としているのは、20 番目のイベントと次のイベントがデータ ウィンドウ ビューに入ったときに時間を記録することです。ボリンジャーバンドの計算結果から得られる開始時刻と終了時刻のとおりです。私の質問は、20 番目のイベントの時間を記録し、同時に次のイベントをウィンドウ ビュー データに入力する方法です。助けてください