WSO2 CEP Siddhi窗口和表格連接不支持Apache Storm

Question

我已經使用WSO2 CEP v4.1.0創建了帶風暴支持的簡單執行計劃。但是，當我在Siddhi使用窗戶設施時，會有一些例外。而且它也不可能與流一起使用風暴來加入桌面。我該如何解決這個問題？有沒有其他選擇。

執行計劃

@Plan:name('ExecutionPlan') 

@Import('InputStream:1.0.0') 
define stream InputStream (id string, param1 int, param2 double, param3 string, param4 string, param5 string, param6 string, param7 string); 

@Export('outputStream:1.0.0') 
define stream OutputStream (id string, param3 string); 

@From(eventtable = 'rdbms' , datasource.name = 'MYSQL' , table.name = 'cep') 
define table cepTable (id string, param1 int, param2 double, param3 string, param4 string, param5 string, param6 string, param7 string); 

@name('query1') 
@dist(parallel='8', execGroup='Filtering') 
from InputStream#window.time(1 sec) 
select id as id, param3 as param3 
insert into OutputStream; 

鑑於錯誤通過CEP

例外：指定了無效的分佈式查詢，出錯轉換 到XML風暴查詢計劃。執行計劃：執行計劃租戶：-1234。 部署查詢時出錯：@name（'query1'）@dist（parallel ='8'， execGroup ='Filtering'）from InputStream＃window.time（1 sec）select id as id，param3 as param3 insert into對於窗口，連接和模式查詢，OutputStream並行性必須爲 1。

Answer 1

當查詢包含窗口，連接或模式時，對於查詢，不能具有> 1的並行度。這是因爲當狀態分佈在多個螺栓上時，這種查詢不能被正確處理。

但是，如果您使用partitions，那麼對於窗口和模式採石場，您可以具有> 1的並行度，因爲一旦分區，每個分區就成爲一個獨立的處理單元，可以獨立執行不同的螺栓。爲了更好地理解這樣的分區查詢，請參閱this sample。