Hi Teena,
I think we just added exactly the feature you are asking for [1].
Dynamic session windows will be release with Flink 1.5.0.
It would be great if you could try the feature and check if it fits your
requirements and works as you'd expect it to work.
Thanks,
Fabian
[1]
Hi,
Is it possible to have a variable value inside the time field for session
window?
input
.keyBy()
.window(ProcessingTimeSessionWindows.withGap(Time.minutes(10)))
.();
In the above code, instead of the value 10, which will be the same for all
records, is it possible to have a
