Siddhi 外部时间 window 问题

Question

我正在尝试计算滑动 window 间隔中的一些统计数据

from CsvInputFileStreamWithConvertedTimestamp#window.externalTime(time, 250 milliseconds) 
select time as timeslice, time:dateFormat(time, 'yyyy-MM-dd') as date, time:dateFormat(time, '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;

但在输出中大多数值为空

这是我的输入数据

知道我做错了什么吗

Answer 1

已解决。

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

Siddhi 外部时间 window 问题

Siddhi externalTime window issue

wso2

complex-event-processing

siddhi