esper

    0

    1答えて

    私はCallPOPDWHイベントがあるとします。イベントには4つの列があります。タイプ列、名前列、検出タイムスタンプ列、および属性列を含む。エスパーは、次の3つのタプルを生成します。 [Event, CallPOPDWH, 1456938481000, {call_start_date=7355448481000, calling_number=+3859121JMOYL, call_direct

    0

    2答えて

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

    0

    1答えて

    続きのパターンを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答えて

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

    0

    1答えて

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

    0

    1答えて

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

    0

    1答えて

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

    0

    1答えて

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