在 Esper 上的间隔上滑动窗口

【问题标题】：Sliding window over an interval on Esper在 Esper 上的间隔上滑动窗口
【发布时间】：2015-07-22 15:59:20
【问题描述】：

如何实现与 Spark Streaming 滑动窗口相同的效果，它在最后一个 Y 窗口长度上以 X 滑动间隔运行。

查看 Esper，应该是 win:time 和 win:time_batch，其中 win:time >= win:time_batch。

【问题讨论】：

【解决方案1】：

在 esper 中相当于声明一个上下文。创建上下文 BucketOf10Sec 开始 @now 10 分钟后结束； Context BucketOf10Sec select sum(price) from MyEvent;

【讨论】：

【解决方案2】：

通过使用win:time 和OUTPUT EVERY x，我设法以不太可定制但更简单的方式（至少对我而言）解决了这个问题

SELECT value
FROM Entry.win:time(10 sec)
OUTPUT EVERY 5 sec

按我的预期工作 - 每 5 秒我会得到最后 10 秒的结果。

【讨论】：