Hi Taher,
To understand your use case, you have something like the following:
stream1.keyBy(…)
.connect(stream2.keyBy(…))
.window(…).apply(MyWindowFunction)
and you want from within the MyWindowFunction to access the state for a FIRED
window when a late element arrives for that
Hi All,
As per my knowledge, all windowing operators in flink are
stateful. So let's say I have 2 streams, Stream1 and Stream2.
Stream1 and Stream2 are aggregated over some key and which is then windowed
on EventTime. So record X from Stream1 reaches flink on time, however,
record X' from
