esper

0熱

2答えて

コンテキストを使用して60分以上の値を集計する際に、esperで過度のメモリ使用量が発生する

1時間ごとにセンサ値を集計したい。時間情報は、イベントストリーム内のタイムスタンプから得られます。そのために、私は4つのEPL文作成しました：を最初の文はsensorId でイベントを仕切るコンテキストを宣言する2番目のステートメントは、Aのイベントストリームにおける時間 - 1日の変化を検出し、特定のセンサーが発生したときにイベントを送信します。 3番目のステートメントは、イベントをsenso

0熱

1答えて

エスパーチェーンに続いてパターンがn回繰り返されますか？

続きのパターンをn回連鎖リピートすることはできますか？私は、例えば、以下のパターンを記述する場合 every a=A -> b=B(b.price < a.price) -> c=C(c.price < b.price) -> d=D(d.price < c.price) -> e=E(e.price < d.price) -> f=F(f.price < e.price) -> g=

0熱

1答えて

Nesperエンジン/ C＃：現時点での問題

C＃でNesperエンジン（http://www.espertech.com/esper/nesper.php）を使用していますが、問題が発生しています。エンジンの内部時刻を取得しようとすると、昨日の日付であるため、返された日付が間違っているようです。以下のコードは、問題を再現したダミーサンプルです。「engineTime」と「DateTime.UtcNow」は等しいはずですが、これは当ては

0熱

1答えて

Esperエラー：エラーcom.espertech.esper.timer.EPLTimerTask - タイマスレッドが未処理の例外を検出しました：null

このエラーはEsperで発生します。原因は何ですか？ [com.espertech.esper.Timer-EsperService-0] ERROR com.espertech.esper.timer.EPLTimerTask - Timer thread caught unhandled exception: null java.lang.StackOverflowError

0熱

1答えて

エスパーグループ出力、複数のnewEvents

は私のEPLは単純です： select symbol, sum(price) from MarketData(symbol!='').win:time(5.5 sec) group by symbol リスナー： update(EventBean[] newEvents, EventBean[] oldEvents) { System.out.println(newEvents.le

0熱

1答えて

Esper TechのEPLオンラインツールでは、ステータス0

を受け取ります。Esper EPL Online Toolは、フォームに書かれているデフォルトの例でテストしています。しかし、「Submit」ボタンをクリックすると、「Status 0」というメッセージが表示されます。例をそのまま実行するか、何か不足していますか？オンラインツールに問題はありますか？ありがとうございます。

0熱

1答えて

ウィンドウでmax（val）とmin（val）のタイムスタンプを取得するにはどうすればよいですか？

NAMED WINDOWまたはWINDOWでMAX（val）とMINvalのタイムスタンプを取得するにはどうすればよいですか？ウィンドウ： [ t1- 100 t2- 200 t3- 250 t4- 900 ] ウィンドウは、私がその最大値とその分値とT4によるT1たいリリースされるたびに。 NAMED WINDOWでサブクエリを試しましたが、サブクエリでの集計はできません。代わり

0熱

1答えて

ESPER EPLイベントのバッチ処理方法

このような通知イベントをバッチしようとしていますが、通知イベントが1つあります。誰でも助けてくれますか？ Thnksです。関連書類 INSERT INTO Notification SELECT d.id as id,a.stationId as stationId,d.firebaseToken as firebaseToken, d.position as devicePos,a.locat

0熱

1答えて

Esper：時間積算ウィンドウにイベントを追加すると、属性の条件が1つ提供されました。

最近私はEsperで作業していましたが、ドキュメントには載っていない機能がありますが、存在する可能性があります。誰もが15秒間ポップアップを表示しなくなるまで、いくつかのイベントを保存したいと思います。つのクエリは、正確には、それはだん： select rstream * from MyEvent.win:time_accum(15 sec) 私は select rstream * fro