ESPER。与最小值发送数据

Question

我把数据转换成艾斯波与类型：

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

我想有一分钟的价格从每分钟的象征。当我做这样的事情：

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

我得到了很多与同价位（最低报价），但不同的符号事件（我想只有一个符号有（每分钟）只有一个事件和价钱）。

Answer 1

它的行为与SQL查询类似，并为每行和批量最小值提供了符号。 就像在SQL中一样，您可以使用“group by”来控制聚合操作的级别。

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

顺便说一下，批处理窗口将事件保留在内存中。有一个“输出快照”，因此不需要批处理窗口。