0

目前我正在使用Esper事件处理器。情况如下:

有一个服务器从客户端接收多条消息,这些消息被插入到一个流中。目前有两种类型的流,称为str1、str2,它们都包含不同的事件类型。为了对齐来自不同客户端的消息,我正在寻找一种对齐机制。

一个事件类型(type1)的包包含绝对时间信息,称为globaltime的变量。现在的挑战是对type1的不同客户端的事件进行排序,因此type2的事件可以通过来自 type1 事件顺序的信息进行排序。

我的第一个直觉是使用x秒的时间窗口并使用ORDER BY子句。但是,我如何根据type2事件的顺序对type1事件进行排序。

我希望这个解释足够清楚,可以提出一些建议或提示。

提前谢谢。

Grtz Mv2k

4

1 回答 1

0

埃斯珀中有一个时间顺序窗口似乎可以完成这项工作

于 2011-06-01T15:49:59.067 回答