siddhiで時間管理

Question

ホワイトリストを2分保存する必要がありますが、新しいストリームが到着したときに私のホワイトリストを使ってクエリを実行する必要があります。私は次のコードで2つのストリームを使用しています：

2分ごとに更新されるWHITELISTを請求する必要があります。

define trigger periodicalTriggerStream at every 2 min; 

from DSB_TEMPORAL#window.time(2 min) 
select wlist:whitelist() as whitel , DSB_licensekey, flg_urldsb 
insert into temporal; 

新しいイベントが到着したときにこのクエリを実行する必要があります。 （私はホワイトリストを使用します）

それは可能ですか？

Answer 1

これは機能しますか？イベントウィンドウで新しいイベントに参加し、その後＃1 window.length（1）に結果を保存して、ホワイトリスト（）ごとに2分：

define trigger periodicalTriggerStream at every 2 min; 

from periodicalTriggerStream 
select wlist:whitelist() as whitel 
insert into whitelStream; 

from whitelStream#window.length(1) join newEventStream 
select findwlist:findwhitelist(DSB_licensekey, flg_urldsb, whitel) as flg_url11 
insert into temporal_WL11; 

基本的な考え方は、あなたがwlistを計算です。