在 siddhi 中加入触发器

Join with trigger in siddhi

我有一个问题。我正在使用 DAS 3.0.1.

Trazablack 是一个 postgres table。

我无法加入事件 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 

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

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

WSO2 说:

  1. Join以两个流作为输入

  2. 每个流必须有关联的 window

  3. 它生成由每个流中的一个事件组成的输出事件

  4. 使用“on” Siddhi 只加入符合条件的事件
  5. 使用“within”,Siddhi 仅加入彼此在该时间范围内的事件