Eseper 事件超时

【问题标题】：Eseper event timeoutEseper 事件超时
【发布时间】：2016-12-14 03:50:07
【问题描述】：

我想为 esper 中的每个传入事件单独超时事件。如何做到这一点？如果我使用时间或批处理窗口，它将等待其他事件首先填充窗口，然后才将事件移动到 rstream。

【问题讨论】：

【解决方案1】：

使用带有 keep-all 的命名窗口，并将删除事件时的条件放入 on-delete。

create window CustomExpiryWindow.win:keepall() as MyEvent
insert into CustomExpiryWindow select * from MyEvent
on <.......> delete from CustomExpiryWindow where <......>

在 Alternative 中有一个用于数据窗口的扩展 API，您可以在其中编写代码来保留和过期事件。

【讨论】：