2014-09-25 56 views
0

我把數據轉換成艾斯波與類型:ESPER。與最小值發送數據

{"symbol" :string 
"price" :double} 

我想有一分鐘的價格從每分鐘的象徵。當我做這樣的事情:

select min(price), symbol 
from Market.win:time_batch(60 sec) 

我得到了很多與同價位(最低報價),但不同的符號事件(我想只有一個符號有(每分鐘)只有一個事件和價錢)。

回答

0

它的行爲與SQL查詢類似,併爲每行和批量最小值提供了符號。 就像在SQL中一樣,您可以使用「group by」來控制聚合操作的級別。

select min(price), symbol from Market.win:time_batch(60 sec) group by symbol 

順便說一下,批處理窗口將事件保留在內存中。有一個「輸出快照」,因此不需要批處理窗口。