目前我正在使用Esper事件处理器。情况如下:
有一个服务器从客户端接收多条消息,这些消息被插入到一个流中。目前有两种类型的流,称为str1、str2,它们都包含不同的事件类型。为了对齐来自不同客户端的消息,我正在寻找一种对齐机制。
一个事件类型(type1)的包包含绝对时间信息,称为globaltime的变量。现在的挑战是对type1的不同客户端的事件进行排序,因此type2的事件可以通过来自 type1 事件顺序的信息进行排序。
我的第一个直觉是使用x秒的时间窗口并使用ORDER BY子句。但是,我如何根据type2事件的顺序对type1事件进行排序。
我希望这个解释足够清楚,可以提出一些建议或提示。
提前谢谢。
Grtz Mv2k