complex-event-processing - 埃斯珀。发送具有最小值的数据

Question

我使用以下类型将数据放入 Esper：

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

我希望每分钟都有一个最低价格的符号。当我做这样的事情时：

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

我得到了很多价格相同（最低价格）但符号不同的事件（我希望只有一个事件（每分钟）只有一个符号和价格）。

Answer 1

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

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

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