2016-02-08 2 views
0

Есть ли какой-либо документ/статья, объясняющая жизненный цикл события в WSO2 CEP? Я не совсем понимаю, как события отбрасываются из потоков событий.Жизненный цикл WSO2 CEP

Спасибо, Уго Calado

+0

Не является ли это полезно? https://docs.wso2.com/display/CEP310/Getting+Started+with+CEP –

+1

Я уже прочитал эту статью и выполнил несколько примеров. Однако я не могу понять, каковы критерии WSO2 CEP, чтобы отметить событие как одноразовое. Событие не может жить в памяти навсегда, иначе у нас будут ошибки в памяти. –

ответ

1

События будут удалены немедленно. Основной поток - это поток, который будет получать события от и приемников, и он сразу же отправит события издателю без сохранения. Если вы хотите собирать событие в течение определенных периодов времени, вы можете использовать что-то наподобие временных окон в Планах исполнения Сиддхи [1].

В следующем запросе Сиддхи он собирает события в течение 10 минут и вставляет в AvgTempStream путем вычисления среднего потока. В этом случае события будут храниться в памяти в течение 10 минут.

from TempStream#window.time(10 min) 
select avg(temp) as avgTemp, roomNo, deviceID 
insert all events into AvgTempStream; 

[1] https://docs.wso2.com/display/CEP400/SiddhiQL+Guide+3.0#SiddhiQLGuide3.0-Window

Смежные вопросы