WSO2のCEP - SiddhiQL - 同じイベントテーブル

Question

からの和異なる行は、私はEVENTCOUNTと呼ばれる1つのイベントテーブルを持っているし、次の値があります。

ID | eventCount 
1   3 
2   1 
3   5 
4   1 

私はの値をカウントどこに来るデータのストリームを持っていますある期間（1秒）の特定の型であり、型と期間に応じて、対応する行にcount（）の値を書き込みます。

私は、イベントテーブル内の値の合計を作る必要があります。

私は別のイベントテーブルを作成して、両方に参加しようとしました。私はあなたのエラーを取得していますが、2つの静的なソースから参加することはできません。

あなたのシナリオでは

Answer 1

WSO2 CEPにSIddiQLからこれを行うための正しい方法は何ですか、イベントテーブル内の値の合計が、それは、イベントの合計数に相当しないのですか？なぜあなたはそれをイベントテーブルにしておく必要がありますか？

@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; 

PS：あなたは本当にイベントテーブルが必要な場合、あなたは常に2つの別々のテーブルにtotalCountStreamとperIdCountStreamを持続することができます。