在 siddhi 中加入触发器

Question

我有一个问题。我正在使用 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

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

Answer 1

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

WSO2 说：

Join以两个流作为输入
每个流必须有关联的 window
它生成由每个流中的一个事件组成的输出事件
使用“on” Siddhi 只加入符合条件的事件
使用“within”，Siddhi 仅加入彼此在该时间范围内的事件

在 siddhi 中加入触发器

Join with trigger in siddhi

wso2

complex-event-processing

siddhi