WSO2 СЕР - SiddhiQL - сумма разные строки из одной и тех же таблиц событий

Question

я одну таблицы событий под названием eventCount и имеет следующие значения:

ID | eventCount 
1   3 
2   1 
3   5 
4   1 

У меня есть поток данных, поступающих в котором я рассчитывать значение определенный тип для периода времени (1 секунда) и в зависимости от типа и периода времени я буду считать() и записать значение count() в соответствующей строке.

Мне нужно сделать сумму значений в таблице событий.

Я попытался создать другую таблицу событий и присоединиться к обоим. Хотя я получаю ошибку, вы не можете присоединиться к 2 статическим источникам.

Что такое правильный способ сделать это из SIddiQL в WSO2 СЕРАХ

Answer 1

В вашем случае сумма значений в таблице событий эквивалентна общее число событий, не так ли? Итак, почему вам нужно держать таблицу событий, разве вы не можете это сделать тогда и там (например, ниже)?

@Import('dataIn:1.0.0') 
define stream dataIn (id int); 

@Export('totalCountStream:1.0.0') 
define stream totalCountStream (eventCount long); 

@Export('perIdCountStream:1.0.0') 
define stream perIdCountStream (id int, eventCount long); 

partition with (id of dataIn) 
begin 
    from dataIn#window.time(5 sec) 
    select id, count() as eventCount 
    insert into perIdCountStream; 
end; 

from dataIn#window.time(5 sec) 
select count() as eventCount 
insert into totalCountStream; 

пс: если вы действительно нужны таблицы событий, вы всегда можете оставаться totalCountStream и perIdCountStream в двух отдельных таблицах.