此执行计划是否满足要求？

Question

我实际上是Wso2和Siddhi的新手。首先，让我解释一下我要做的事情。我正在尝试连接两个流（RG和MW）并将查询的结果插入（OutStream）。我正在尝试获取具有读数值>阈值的传感器名称。下面是我的试用版，我试图弄清楚它是否正如我试图做的那样，当我试图为（OutStream）定义UI发布者时没有出现。谢谢。

@Import('From_Middle_Ware:1.0.0')
define stream MW (meta_SensorID string, SensorReadingValue double, Priority 
int);

@Import('FromRGModule:1.0.0')
define stream RG (meta_TempID int, correlation_InSensor string, 
correlation_OutSensor string, correlation_ActionToOutSensor double, 
Threshold double);

@Export('OutStream:1.0.0')
define stream Filtered (meta_SensorName string, SensorValue double);

from MW #window.length(2000) as A
join RG #window.length(2000) as B
on A.meta_SensorID== B.correlation_InSensor and 
A.SensorReadingValue>B.Threshold
select A.meta_SensorID , A.SensorReadingValue
insert into OutStream;