2017-05-01 22 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;"; 

是否有可能在碳控制檯中顯示以上輸入和輸出事件流?

我曾嘗試將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;