2017-05-01 10 views
0

WSO2 CEP에서 몇 가지 계산을 수행하는 사용자 지정 기능이 있습니다. 다음과 같은 쿼리가 있습니다.Siddhi Jar가 탄소 콘솔에 나타나지 않습니다.

String cseEventStream = "define stream eventStream (attribute string,attributeValue object);"; 

String query = "from eventStream#window.timeBatch(10,0)\n" + 
"select timestamp,custom:function(attribute,attributeValue) as data\n" + 
     "insert into outputStream;"; 

Carbon 콘솔에서 위의 입력 및 출력 이벤트 스트림을 표시 할 수 있습니까?

jar 파일을 respository/components/dropins 폴더에 넣으려고했지만 탄소 콘솔에서 스트림을 볼 수 없습니다.

답변

0

Siddhi Logger을 사용하여 이벤트를 기록/인쇄 할 수 있습니다. 아래와 같이 사용할 수 있습니다.

define stream eventStream (attribute string,attributeValue object); 

from eventStream#window.timeBatch(10,0)#log("eventStream Event: ") 
select timestamp, custom:function(attribute,attributeValue) as data 
insert into outputStream; 

from outputStream#log("outputStream Event: ") 
insert into tempStream;