筛选 Siddhi 中的先前事件

Question

是否有可能在 Siddhi 中检测到之前的事件是否发生在当前事件之前？我正在尝试做类似 "send alert if Y happened after X" 的事情。我已经通过类似于此的查询获得了该工作的反面（如果 Y 发生而 X 从未发生则发送警报）：

from s1=inStream[value == 'Y'] and  
    not inStream[value == 'X'] 
    select s1.person  
    insert into outStream

并希望我能够通过简单地删除 "not" 来使我的预期查询工作，但是那没有用。

Answer 1

使用以下查询

from s1=inStream[value == 'X'] -> s2= inStream[value == 'Y'] 
select s1.person, s2.person   
insert into outStream;

如果您想限制 X 和 Y 之间的时间（始终推荐），请使用

from s1=inStream[value == 'X'] -> s2= inStream[value == 'Y'] within 10 min
select s1.person, s2.person   
insert into outStream;

Filtering on prior events in Siddhi