使用Esper变量来增大和缩小时间窗口

Question

我有一个时间窗口和一个变量，它是时间窗口的参数。

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

在我调用的代码中设置expireSecs值。

epRuntime.setVariableValue("expireSecs", 5);

时间窗口似乎不会从10秒到5秒。

Answer 1

表达式窗口和表达式批处理窗口是唯一连续重新评估参数表达式的窗口。时间窗口不会重新评估。该文档有这个here。以这种方式在表达式窗口description中有一个例子。

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