WSO2 CEP 流计数功能重启

Question

我有以下查询：

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

是否可以重新启动流的 count() 函数？

如果没有，我该如何避免呢？如果可以的话。

Answer 1

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

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

但是，如果您需要通过向计数器发送参数来重置计数器（即 count(bool reset)），您可能必须按照以下 documentation 中所述编写自己的自定义聚合函数。