Session Window set max timeout

[ant burton]

Is it possible to limit session windowing to a max of n seconds/hours etc?

i.e. I would like a session window, but if a session runs for an unacceptable amount of time, I would like to close it.

Thanks,

[Timo Walther]

Hi,

I would recommend to implement your custom trigger in this case. You can override the default trigger of your window:

https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/operators/windows.html#triggers

This is the interface where you can control the triggering:
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/Trigger.java

I hope this helps.

Regards,
Timo


Am 10/2/17 um 4:42 PM schrieb ant burton:

Is it possible to limit session windowing to a max of n seconds/hours etc?

i.e. I would like a session window, but if a session runs for an unacceptable amount of time, I would like to close it.

Thanks,