2017-05-03 3 views

답변

2

count() 또는 창없는 집계 함수를 사용하는 경우 해당 집계자가 누적되는 이벤트를 재설정 할 수 없습니다. 예를 들어 아래와 같은 창을 사용하면 10 개의 이벤트를받은 후 카운터가 재설정됩니다.

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

그러나, 당신은 당신이 다음 documentation에 설명 된대로 사용자 정의 집계 함수를 작성 할 수 있습니다, 여기에 (즉 count(bool reset)을)이 매개 변수를 전송하여 카운터를 재설정해야합니다.

+0

지금 창을 사용 중입니다. stream1에서 만들기 # window.time (5 분) 항목으로 count()를 선택 newStream에 isnert; 하지만 지금은 처음 5 분 밖에 안 남았습니다. 연속 시간 창이 아닙니다. – JoaoFilipeClementeMartins

+0

'시간'창이 계속됩니다. 주어진 시간에 마지막 windowTime 기간 동안 도착한 이벤트를 보유하는 슬라이딩 시간 창이며 각 이벤트 도착 및 만료마다 업데이트됩니다. 당신이, 이벤트마다 5 분을 처리하는 배치로, 당신은 창 'timeBatch "를 사용해야 할 경우. 그것은 windowTime 기간 동안 도착하는 이벤트를 보유하고 배치 (텀블링) 시간 창, 그리고 각 windowTime에 대한 업데이트됩니다. 설명서 참조 : https://docs.wso2.com/display/CEP420/Inbuilt+Windows –