Output snapshot in Esper

466 Views Asked by Fergus Incrisis At 05 April 2025 at 00:27

I created an std:unique(Id) window in esper as in

select * from MyData.std:unique(Id) where rate > 0 output snapshot every 60 seconds;

What I expected was that at the end of every 60 seconds, I will get a list of all Data rows:

  Id: 5  Rate: 20
  Id: 2  Rate: 45
  Id: 3  Rate: 22

Instead all I get is just the last row (Id:3 Rate: 22). I also tried "snapshot all" and that did not help either.

Is there a way to produce a result set of all the event that happened in 60 seconds window unique by Id - just the most recent ones?

There are 0 best solutions below