Esper：添加一个事件到Time-Accumulating窗口提供了一个条件属性

Question

我最近一直在使用Esper，并且有一个我在文档中遗漏的功能，但它可能存在。

我想存储一些事件，直到没有人弹出15秒，当它发生时释放他们。

一个查询正是这么做的，它是：

select rstream * from MyEvent.win:time_accum(15 sec) 

我可以在MyEvent添加条件像

select rstream * from MyEvent where status = 'ALARM_END'.win:time_accum(15 sec) 

这完美的作品。

现在我想对EVENTTYPE属性添加一个条件说：

如果一个新的事件触发与EVENTTYPE XXXX但已经有一个在窗口EVENTTYPE XXXX的事件，然后不加这个新的弹出窗口事件（因此不要停止秒表从0到15秒）。

有没有办法做到这一点？

非常感谢！

编辑：

寻找更深入地进入我的需要和ESPER文件，我想我需要的是更满意

select * from MyEvent.win:time_length_batch(15 sec, 2) 

我不认为我需要rstream，我只是想积累要么1或2个元素并将它们全部在一个数组中一次全部（新事件很好）。

但是，是否有可能在第一个（也是第一个）MyEvent进入窗口时添加一个条件？这是状态='ALARM_END'。

Answer 1

您可能有一个命名窗口，并在插入之前检查该窗口。

// define named window 
create window MyEventWindow#time_accum(15) as MyEvent; 

// insert events that don't have 'xxx' 
insert into MyEventWindow select * from MyEvent(eventType != 'xxx'); 

// insert events that have 'xxx' only if not already there 
insert into MyEventWindow select * from MyEvent(eventType = 'xxx') 
    where not exists(select * from MyEventWindow where eventType='xxx'); 

// usual select 
select rstream * from MyEventWindow;