Esper生成集

Question

我想使用Esper生成事件的插曲。我试图在每一段时间内检测机器人运动的变化，并想知道什么是最好的实现方式。

从事件中产生剧集的规则是：

• 如果新的活动时间(如。7秒，机器人A的超过3秒比最近的事件(例如。3秒，机器人A)同一机器人，新事件属于新的一集。
• 每集应该只代表一个机器人(例如。2秒，robotA和3秒，robotB应该输出2集)

输入数据：

Event   Time     Robot     Position
1         1        A         0
2         2        A         1
3         6        A         2

产出数据应是：

Array[0]={Event 1,Event 2}
Array[1]={Event 3} //more than 3 sec

输入数据：

Event     Time     Robot     Position
1         1        A         0
2         2        A         1
3         4        B         0
4         6        A         2

产出数据应是：

Array[0]={Event 1,Event 2}
Array[1]={Event 3} //different robot
Array[2]={Event 4}

请提供建议。我试过使用多个侦听器，每个机器人一个，创建插曲，它可以工作，但我试图使用一个EPL语句来完成它。我尝试过win:time_accum(3sec) group by robot，但是第二个示例输出：

Array[0]={Event 1,Event 2, Event 4}
Array[1]={Event 3}

当每次事件进入时，时间窗口都会被移动，系统仍然认为事件4由于事件3而小于3秒。我如何为每个机器人创建一个唯一的时间窗口？

谢谢你的建议和任何帮助，我们非常感谢。

Answer 1

我认为表达式批处理窗口将完成这项工作，它允许比较和输出不包括当前事件的批处理。