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