Используйте переменную Esper, чтобы увеличить и уменьшить временное окно - PullRequest
0 голосов
/ 23 марта 2019

У меня есть временное окно и переменная, которая является параметром для временного окна.

CREATE VARIABLE int expireSecs = 10;
SELECT * FROM Event#time(expireSecs sec);

В коде, который я вызываю, чтобы установить значение expireSecs.

epRuntime.setVariableValue("expireSecs", 5);

Похоже, что временное окно не изменяется от 10 до 5 секунд.

1 Ответ

0 голосов
/ 25 марта 2019

expression-window и expression-batch-window - единственные окна, которые непрерывно переоценивают выражения выражений. Временное окно не переоценивается. В документации есть здесь . Вот пример в окне выражений description , таким образом.

select * from MyEvent#expr(oldest_timestamp > newest_timestamp - (1000*expirySec))
...