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.
我正在尝试从类型 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.