WSO2 CEPストリームCount関数再開

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; 

しかし、あなたは、次のdocumentationで説明するように、独自のカスタム集計関数を記述する必要があり、それには（すなわちcount(bool reset)）のパラメータを送信することにより、カウンタをリセットする必要がある場合。