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 

Кстати, окно партии сохраняет события в памяти. Существует «выходной снимок», поэтому нет необходимости в пакетном окне.