合并siddhi中两个流的属性

Question

我的意图是合并siddhi中两个流的属性。

我正在使用带有窗口属性的“ join”来合并我的siddhi查询中的两个流，并将连接的结果输入到另一个流中以使其丰富。

当传入事件以1秒或更长的固定间隔进入时，窗口属性（window.time（1秒）或window.length（1））效果很好。

[同时（例如10或100）事件在同一时间（在一秒钟之内）发送。然后，连接的结果不是预期的。

from EventInputStreamOne#window.time(1 sec) as i
        join EventInputStreamTwo as s
        on i.variable2 == s.variable2
select i.variable1 as variable1, i.variable2 as variable2, s.variable2 as variable2
insert into EventOutputStream;

请让我知道是否有任何方法可以合并两个流，即使一次（在一秒钟之内）发送的事件数量很大，也必须唯一地处理/处理传入的事件。

Answer 1

您能否详细说明您的意思

然后联接的结果不是预期的术语。

哪个流EventInputStreamOne或EventInputStreamTwo以更高的速率接收事件。

根据您的Siddhi应用程序，1sec中流到EventInputStreamOne流的事件将与EventInputStreamTwo中的每个事件进行比较，匹配的事件将输出到EventOutputStream。” >

如果要在1秒内比较同时出现在EventInputStreamOne

和EventInputStreamTwo上的事件，则在[[EventInputStreamTwo处的时间窗口也应为1秒。 检查Siddhi documentation on Joins了解更多详细信息。