WSO2 CEP数据流计数功能的重新启动

Question

我有以下查询：

from stream1 
select count() as item insert into newStream; 

是否有可能重启流的count（）函数？

如果不是，我怎样才能绕过这个？如果可能的话。

Answer 1

如果您使用count()或没有窗口的任何其他聚合函数，则无法重置在该聚合器中累积的事件。例如，如果您使用下面的窗口，它会在收到10个事件后重置计数器。

from stream1#window.lengthBatch(10) 
select count() as item insert into newStream; 

但是，如果你需要发送一个参数给它，（即count(bool reset)）到柜台重置你可能有如下所示documentation描述编写自己的自定义聚合函数。