我的目的是合并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;
请让我知道是否有任何方法可以合并两个流，即使一次(一秒内(发送的事件数量很大，也必须唯一地处理/处理传入的事件。
你能详细说明一下你的意思吗
则联接的结果不是预期的。
哪个流 EventInputStreamOne 或 EventInputStreamTwo 以更高的速率接收事件。
根据您的 Siddhi 应用程序，1 秒内到达EventInputStreamOne的事件流将与EventInputStreamTwo中的每个事件进行比较，匹配的事件将输出到EventOutputStream。
如果要比较在 1 秒内同时到达EventInputStreamOne和 EventInputStreamTwo 的事件，请在EventInputStreamTwo上设置一个 1 秒的时间窗口。
查看有关联接的 Siddhi 文档以获取更多详细信息。