Esper 根据过滤器创建 window

Esper create window based on filter

我正在尝试从类型 TickVo 构造一个 window 对象。 我设法使用:

TickVO.win:time_batch(1 min)

但是我的第一个刻度从例如午夜后 44 毫秒开始,意思是 00:00:00.44.

我的问题是: 我怎样才能使 window 从 0 毫秒开始并以此结束。 例如:00:00:00.44 将添加到 00:00:01 的 window 但是 00:00:01.15 tick 将添加到 00:00:02.

的 window

因为现在发生的是 00:00:00.44 和 00:00:01.15 都添加到第一个刻度,因为(如我所见)它与起点相关。

更新:经过进一步调查,我发现我的解决方案应该依赖于

win:ext_timed

但我还没有想出我应该用作 timestamp_expression

的过滤器

时间批次可以将参考点作为“TickVO#time_batch(1 min, 0L)”形式的parameter。零告诉运行时对齐到 0 毫秒。

solution patterns page 上有一些相关的方法。 您可能会发现有关 batch windows behave 如何有用的详细说明。 会话 windows 通常使用重叠或非重叠 contexts.