Запрос Esper EPL для времени (t) и времени (t-1)

Я пытаюсь реализовать запрос EPL, который может получить среднее значение для времени (t) и времени (t-1).

Например:

а) в первые 5 секунд (секунды 0-5) происходит 2 события со средним значением 12

б) в следующие 5 секунд (секунды 5-10) есть 3 события со средним значением 23 , и в запросе EPL, который перехватывает эту информацию, я также могу увидеть среднее значение 12 из предыдущего временного окна первые 5 секунд

Моя идея состоит в том, чтобы расположить объекты/запросы таким образом, чтобы окончательный запрос epl имел моментальный снимок времени (t) и времени (t-1), как показано в виртуально созданном объекте ScoreInfoBeforeAfter . Однако это не работает.

Любые идеи очень приветствуются. Спасибо.

~~~~

// The object being published to the Esper stream:
class ScoreEvent { int score; ... }

esper epl
person Gene Bo    schedule 26.10.2010    source источник

Ответы (1)


arrow_upward
7
arrow_downward

Похоже, ключевое слово до является решением.

http://esper.codehaus.org/esper-2.1.0/doc/reference/en/html/functionreference.html

См.: Раздел 7.1.9

Что касается примера, который я описал в исходном сообщении, вот соответствующее решение, которое я нашел. Кажется, он работает правильно.

INSERT INTO ScoreInfo
SELECT 
    'ScoreInfo' as a_Label, 
    average AS curAvg, 
    prior(1, average) AS prevAvg 
FROM 
    ScoreEvent.win:time_batch(5 sec).stat:uni(score);


SELECT
*
FROM
ScoreInfo.win:length(1);

..
И это хорошо, потому что вы можете делать такие вещи:

SELECT
    'GT curAvg > prevAvg' as a_Label, 
    curAvg, 
    prevAvg 
FROM
    ScoreInfo.win:length(1)
WHERE
    curAvg > prevAvg;


SELECT
    'LTE curAvg <= prevAvg' as a_Label, 
    curAvg, 
    prevAvg 
FROM
    ScoreInfo.win:length(1)
WHERE
    curAvg <= prevAvg;
person Gene Bo    schedule 27.10.2010