Siddhi外部时间窗口问题

问题描述

我正在尝试以滑动窗口间隔计算一些统计数据

from CsvInputFileStreamWithConvertedTimestamp#window.externalTime(time,250 milliseconds) 
select time as timeslice,time:dateFormat(time,'yyyy-MM-dd') as date,'HH:mm:ss') as time,instrument,sum(fin) / sum(quantity) as vwap,max(price) * min(price)-1 as prange,max(price) as prangemax,min(price) as prangemin,sum(quantity) as totalquant,avg(quantity) as avgquant,0 as medquant,sum(fin) as totalfin,avg(fin) as avgfin,count() as Trades,distinctCount(buyer) as nofbuy,distinctCount(seller) as nofsell,cast(distinctCount(seller),'double') / distinctCount(buyer) as bsratio,count(buyer) as buyaggr,count(seller) as sellaggr,sum(quantity) as totalblockquant 
insert expired events into OutputStream;

但在输出中大多数值为空

这是我的输入数据

知道我在这里做错了什么

解决方法

解决了。

我使用的是 insert expired events into 而不是 insert all events into