Siddhi Jar не появляется в углеродной консоли

В WSO2 CEP у меня есть пользовательская функция, которая выполняет некоторые вычисления; У меня есть запрос, подобный следующему

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 Console?

Я попытался поместить файл jar в папку respository/components/dropins, но я не могу видеть потоки в углеродной консоли.


wso2 complex-event-processing siddhi
person Mujahid Masood    schedule 01.05.2017    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Для ведения журнала/ распечатать события. Вы можете использовать его, как показано ниже;

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;
person Grainier    schedule 02.05.2017