Esper (C.E.P.) 查询每整分钟计算一次烛台

Question

我正在使用复杂事件处理 (Esper) 技术在我的系统中提供实时烛台计算。我在计算值方面做得很好，但是我发现很难确保蜡烛窗口从整分钟开始(一分钟蜡烛)并在下一分钟开始之前结束(即蜡烛 1[06:00.000 - 06:00.999]，蜡烛2[06:01.000 - 06:01.999] 等...)。

Esper 的查询语言中是否有能够提供此类功能的模式或命令？

我很感激 build 性的意见和指导。

Answer 1

在 Esper 中，您可以使用一种模式在零秒处每分钟触发一次，即
插入 TriggerEvent select * from pattern[pattern[every timer:interval(1 min).]
//保存蜡烛数据的命名窗口，计算下一个蜡烛
on TriggerEvent select * from NamedWindowCandle ....
//删除旧数据
在 TriggerEvent 上从 NamedWindowCandle 中删除

-rg