java - Esper : 在 Security 上分组 Tick 数据，查找一天中的最大值和最小值。然后进行进一步的计算

Question

我无法解决 Esper 中的某个问题。我必须检查当前的 Tick 值是否从昨天的 Max Value 上升。这是每 24 小时返回最大值和最小值的代码。

insert into
DayEnd
select
max(last) as high,
min(last) as low,
security
from
Tick.std:groupwin(security).win:time_batch(1440 minutes) group by security;

我必须在多个证券上运行它，所以我必须检查每个证券。

Answer 1

对于如此大的批处理窗口，批处理窗口不是正确的方法。这是因为批处理窗口保留了所有事件。

请改用上下文声明。上下文允许您构建分析的生命周期。下面是一个示例，更多示例在解决方案模式中。此示例是 2 个语句，版本 4.10，未检查语法：

创建上下文 Batch24Hour 作为 start @now 在 24 小时后结束；

context Batch24Hour select max(last) as high, min(last) as low, security from Tick group by security output when terminate;