我正在尝试实现一个 EPL 查询,该查询可以获取 Time(t) 和 Time(t-1) 的平均值。
例如:
a)在前 5 秒(秒 0-5)内有 2 个事件,平均为 12
b)在接下来的 5 秒(5-10 秒)内,有 3 个事件的 avg 为 23 ,并且在捕获此信息的 EPL 查询中,我还能够从上一个时间窗口中看到 12 的 avg前 5 秒
我的想法是错开对象/查询,使最终的 epl 查询具有 Time(t) 和 Time(t-1) 的快照,如虚拟创建的对象 ScoreInfoBeforeAfter 所示。但是它不起作用。
任何想法将不胜感激。谢谢。
~~~~
// The object being published to the Esper stream:
class ScoreEvent { int score; ... }