Re: Running averages -- but global window state might not be enough

2021-04-21 Thread Reuven Lax
Can you store the history in an OrderedListState? This state should allow you to efficiently delete old versions. On Tue, Apr 20, 2021 at 9:58 AM Raman Gupta wrote: > I have a running average problem. As I understand it, the traditional Beam > solution is state in a global window, but I'm not qu

Running averages -- but global window state might not be enough

2021-04-20 Thread Raman Gupta
I have a running average problem. As I understand it, the traditional Beam solution is state in a global window, but I'm not quite sure how to approach it for my use case, which is a bit more complex. I have a "score" output every 5 minutes based on a timer, up to a maximum of 1 hour after some ti