如何在一個單一的Epser Engine中的多個流中訂購事件

Question

當前我正在使用Esper事件處理器。情況如下：

有一臺服務器從客戶端接收多條消息，這些消息被插入到一個流中。目前有兩種類型的流，稱爲str1，str2，都包含不同的事件類型。爲了調整來自不同客戶端的消息，我正在尋找對齊機制。

一個事件類型的包（type1）包含絕對時間信息，變量名爲globaltime。現在的挑戰是訂購類型1的不同客戶端的事件，因此，類型2的事件可以通過來自類型1事件順序的信息進行排序。

我的第一個直覺是取一個時間窗口x秒和使用ORDER BY子句。但是，那麼如何根據type1的事件排序來訂購type2事件。

我希望這個解釋足夠清楚，可以提出一些建議或提示。

Thnx提前。

Grtz Mv2k

Answer 1

存在艾斯波時間順序窗口似乎做的工作