WSO2 CEP - Вставка в несколько потоков

Question

В SiddhiQL как можно вставлять в несколько потоков с одинаковыми условиями?

Когда у меня есть два коррелированных события (event1 и event2) и вы хотите вставить event1 в streamA; Вставить событие2 в streamB; Вставить abstractEvent в streamC.

Должен ли я писать три запроса Сиддхи?

спасибо.

Answer 1

Да, вам нужно написать несколько запросов Сиддхи в том же плане выполнения, чтобы вставлять события в несколько потоков. Логика, которую вы выбираете для каждого потока, может быть выполнена с использованием фильтра. В следующем случае я вставляю нечетные события meta_id в stream1 и даже в stream2 с помощью фильтра.

@Plan:name('ExecutionPlan') 

@Import('test:1.0.0') 
define stream test (meta_id int, meta_name string); 


from test[meta_id % 2 == 0] 
select * 
insert into stream1; 


from test[meta_id % 2 == 1] 
select * 
insert into stream2;