問題タブ [nesper]

NEsperでユニークIDの車のタイムを計測したい。私の問題は、道路に数台の車があることです。この道路には事前定義されたステップがあります。この車が最後のステップを受け取るまで、最初のステップにあるすべてのユニークな車の時間を止め始めたいと思います。

問題は、特定の ID で車を分離する方法がわからないことです。この例では、車の 1 つが最後のステップを受信すると、イベントはそれ以上発生しません。

ユーザーごとにイベントをグループ化し、バッチで (ユーザーごとに) 返そうとしています。たとえば、3 人のユーザーがそれぞれ 5 つのイベントを送信した場合、5 つのイベントの 3 つのバッチを esper から出力したいと考えています。

次の EPL を使用して、3 つのデータ ウィンドウが作成され、各ウィンドウに 5 つのイベントがあることを検証できます。

select * from EVT.std:groupwin(User).win:time_batch(2).std:size()

ただし、 std:size() を削除すると、15 個のイベントすべてが 1 つのバッチで返されます。私が理解しているように、これは std:groupwin グループ化ウィンドウ ビューが std:merge ビューによって評価される方法によるものです。

すべてをマージせずに、各データ ウィンドウからバッチ処理されたイベントを出力するにはどうすればよいですか?

単純なオブジェクトがあるとしましょう:

StockTick.date または StockTick.unixTimestamp を使用して .win:time() ウィンドウ内で集計するには、次のクエリをどのように変更すればよいですか?

このステートメントは Esper で機能すると確信しています。

しかし、このステートメントはエラーをスローします:

エラーメッセージ：

次に、JOIN を使用しますが、それでも機能しません。

エラーメッセージ：

Esperで2つのテーブルを結合するには?

Nesper アプリケーションを構築していますが、展開後に次のエラーがスローされます。

Esperは、線形回帰の関数 [stat:linest( , )] を提供します。

例は次のようになります (これはうまく機能します):

ただし、シンボル (INTC など) でグループ化されたウィンドウ内のすべてのデータの線形回帰を取得しようとしていますが、許可されません。「having symbol='GE'」を使用してみましたが、それも正しくありませんでした。これが私が試みたものです：

これを解決するための助けをいただければ幸いです。

次のように esper で std:unique(Id) ウィンドウを作成しました

私が期待していたのは、60 秒ごとにすべてのデータ行のリストを取得することでした。

代わりに、最後の行だけが得られます (Id:3 Rate: 22)。「すべてのスナップショット」も試しましたが、それも役に立ちませんでした。

Id によって一意の 60 秒のウィンドウで発生したすべてのイベントの結果セットを生成する方法はありますか?