Handle latancy up to X seconds
Opened this issue · 0 comments
MatejaMaric commented
POSSIBLE SOLUTION:
There should be two HyperLogLog-s and two lastFlush-es.
When a message has a timestamp minus interval that's X seconds longer then the it's lastFlush then the result should be emitted.