0

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

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

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

4

1 回答 1

0

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

WSO2 说：

  1. Join 将两个流作为输入

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

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

  4. 使用“on” Siddhi 仅加入符合条件的事件
  5. 使用“within”，Siddhi 仅加入彼此在该时间范围内的事件
于 2016-05-26T20:55:58.913 回答