2016-05-26 6 views
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 

Моя проблема в том, что этот запрос равен нулю. Зачем?

ответ

0

Прошу прощения, важно прочитать документацию в следующий раз.

WSO2 говорят:

  1. Регистрация занимает два потока в качестве входного

  2. Каждый поток должен иметь связанное с ним окно

  3. Он генерирует выходные данные события, состоящие из одного события из каждый поток

  4. С «on» Сиддхи объединяет только события, которые соответствует условию
  5. С «внутри» Сиддхи соединяет только события, которые находятся за это время друг от друга