"stepless" sliding windows?

Posted by Alex Cruise on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/stepless-sliding-windows-tp38822.html

Hey folks!

I have an application that wants to use "stepless" sliding windows, i.e. we produce aggregates on every event. The windows need to be of a fixed size, but to have their start and end times update continuously, and I'd like to trigger on every event. Is this a bad idea? I've googled and read the docs extensively and haven't been able to identify built-in functionality or examples that map cleanly to my requirements.

OK, I just found DeltaTrigger, which looks promising... Does it make sense to write a WindowAssigner that makes a new Window on every event, allocation rates aside?

Thanks!

-0xe1a