使用Esper变量增减时间window

Question

我有一个时间 window 和一个作为时间参数的变量 window。

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

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

epRuntime.setVariableValue("expireSecs", 5);

时间 window 似乎没有从 10 秒到 5 秒。

Answer 1

expression-window 和 expression-batch-window 是唯一 windows 连续重新计算参数表达式的。时间 window 不重新计算。文档中有这个 here. There is an example in the expression-window description，以这种方式。

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

使用Esper变量增减时间window

Use Esper variable to grow and shrink a time window

esper