Допустим, у меня есть простой объект:
public class StockTick{
private String symbol;
private decimal price;
private Date date;
private int unixTimestamp
}
Как мне изменить следующий запрос, чтобы использовать StockTick.date или StockTick.unixTimestamp для агрегирования в окне .win:time()?
select avg(price) from StockTick.win:time(30 sec) where symbol='IBM'
Если события уже упорядочены по отметке времени unix, вам не нужно изменять запрос. Просто сделайте это для каждого события:
runtime.sendEvent(new CurrentTimeEvent(unixTimestamp));
runtime.sendEvent(stockTickEvent);
В приведенном выше коде используется внешнее время, поэтому отключите внутреннее системное время по умолчанию. Для совершенно неупорядоченных или неустановленных событий вообще не используйте временное окно, а вместо этого подумайте о том, как будет выглядеть группировка.
