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。