1

我在 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 唯一 - 只是最近的事件?

4

0 回答 0