Перезапуск функции подсчета потоков 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)) вам, возможно, придется написать свою собственную функцию агрегирования, как описано в следующей документации.