我有一个查询,可以捕获流中字段的最大值:
from stream1#window.time(1 min)
select max(value1) as max_value1
insert all events into newstream;
,尽管在此窗口之后,我开始在max_value1中获得零值。
我对AVG做同样的事情,但是一旦所有事件从1分钟的时间窗口到期,我总是得到0。
感谢您让我们知道基于SQL的不一致行为,它应该返回null。我们进行了修复,使得AVG((,min((,max((和sum((在表[1]中没有事件时返回null。
确实使用default((或ifthenelse((带有" nes null"的ifthenelse((,以如果需要的话将null转换为扩展的默认值。
[1] https://github.com/wso2/siddhi/pull/344