Thanks for the clarification Dawid. Resolves my confusion.
Sent from Yahoo Mail on Android
On Fri, 19 Mar 2021 at 2:41 pm, Dawid Wysakowicz
wrote:
Hi Chirag,
I agree it might be a little bit confusing.
Let me try to explain the reasoning. To do that I'll first try to rephrase the
rea
Hi Chirag,
I agree it might be a little bit confusing.
Let me try to explain the reasoning. To do that I'll first try to
rephrase the reasoning from FLINK-8560 for introducing the
KeyedProcessFunction. It was introduced so that users have a typed
access to the current key via Context and OnTimerC
Hi,
Currently, both ProcessFunction and KeyedProcessFunction (and their CoProcess
counterparts) expose the Context and TimerService in the processElement()
method. However, if we use the TimerService in non keyed context, it gives a
runtime error.
I am a bit confused about these APIs. Is there
