我在 esper 中创建了一个 std:unique(Id) 窗口,如
select * from MyData.std:unique(Id) where rate > 0 output snapshot every 60 seconds;
我所期望的是,在每 60 秒结束时,我将获得所有数据行的列表:
Id: 5 Rate: 20
Id: 2 Rate: 45
Id: 3 Rate: 22
相反,我得到的只是最后一行(Id:3 Rate:22)。我还尝试了“全部快照”,但这也无济于事。
有没有办法生成在 60 秒窗口内发生的所有事件的结果集,该事件由 Id 唯一 - 只是最近的事件?