我目前有一個訂單對象。我們可以假設它有三個稱爲orderId，狀態和價格的字段。 class Order
{
public int orderId;
public String state;
public int filled;
}
在整個訂單的生命週期中，狀態和填充量會發生變化。每當有一個場變化，我們將其推送到艾斯波運行時經由： Order o .....;
我有一個數據流每10秒發送一個數據包。我需要一個針對Esper的查詢，在設備關閉時生成事件（收到最後一個數據包）。 我認爲，如果沒有數據到達30秒設備丟失，但我需要得到的只有1通知每5小時，直到設備回來，以避免垃圾郵件 這裏是我的基本查詢： select * from pattern [every tick=MyInputStream-> (timer:interval(30 sec) and n
我想創建一個Esper引擎長時間運行的進程，但我不確定Esper的線程模型以及我應該實現的模型。天真地我嘗試以下： public class EsperTest {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
//EPServiceProvide