Aggregation for last n seconds for each event

[oleg]

Hi Community,

I do streaming in event time and I want to preserve ordering and late 
events. I have a use case where I need to fire an aggregation function 
for events of last n seconds(time units in general) for every incoming 
event.

It seems to me that windowing is not suitable since it may be expressed 
either in time or in events count, not "last n seconds for each single 
event".

Is there an idiomatic way to do this? Any examples or help are 
appreciated. Thanks in advance.


Best regards,

Oleg Bonar