2017-05-01 5 views
0

In WSO2 CEP habe ich benutzerdefinierte Funktion, die einige Berechnungen durchführt; Ich habe Abfrage wie folgtSiddhi Jar erscheint nicht in Carbon-Konsole

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;"; 

Ist es möglich, über Eingang und Ausgang Ereignisstrom in Carbon Console anzeigen?

Ich habe versucht, die JAR-Datei in Repository/Komponenten/Dropins Ordner, aber ich bin nicht in der Lage, die Streams in Carbon-Konsole zu sehen.

Antwort

0

Sie können Siddhi Logger zum Protokollieren/Drucken der Ereignisse verwenden. Sie können es wie unten gezeigt verwenden;

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;