2016-05-26 31 views
0

我有问题。我正在使用DAS 3.0.1。在siddhi加入触发器

Trazablack是一个postgres表。

我不能让与事件Trazafiltrada联接,它是用下面的代码创建:

define trigger FiveMinTriggerStream at every 5 min; 

from FiveMinTriggerStream join Trazablack as t 
select t.sensorValue as sensorValue 
insert into TrazaFiltrada; 

但是,我想做出与其他事件不同的加盟,我用下面的代码:

from sensorStream JOIN TrazaFiltrada 
on sensorStream.sensorValue==TrazaFiltrada.sensorValue 
select sensorStream.meta_timestamp, sensorStream.meta_sensorName, 
     sensorStream.correlation_longitude, sensorStream.correlation_latitude, sensorStream.sensorValue as valor1, TrazaFiltrada.sensorValue as valor2 
insert into StreamPaso; 

Trazablack   TrazaFiltrada   sensorStream 
----------   -------------   ------------- 
156     156     156 
170     170 
85     85 

我的问题是这个查询是空的。为什么?

回答

0

对不起,重要的是下次阅读文档。

WSO2说:

  1. 加入需要两个流作为输入

  2. 每个流必须具有相关联的窗口

  3. 它产生来自一个事件组成的输出事件每个流

  4. 与“在”Siddhi加入只有事件匹配条件
  5. “内”中,Siddhi只加入彼此之间的事件