Как в SiddhiQL можно вставлять в несколько потоков с одинаковым условием?
Когда у меня есть два коррелированных события (event1 и event2) и я хочу вставить event1 в streamA; вставить событие2 в потокB; вставить abstractEvent в streamC.
Должен ли я написать три запроса Siddhi?
Спасибо.
Да, вам нужно написать несколько запросов Siddhi в одном плане выполнения, чтобы вставлять события в несколько потоков. Логика выбора событий для каждого потока может быть реализована с помощью фильтра. В следующем случае я вставляю нечетные события meta_id в поток1 и даже в поток2 с помощью фильтра.
@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;
