Hi,
Sorry for my misunderstanding here.
Yes, the RichProcessFunction variant was removed in 1.3.
Now, ProcessFunction has been changed to always be a RichFunction, so access to
the runtime context / lifecycle methods is always available through the
ProcessFunction interface.
You should simply u
yes i see that so shall i update code from RichProcessFunction to
RichFunction(based object)? The implementation throw compile exception as
RichProcessFunction has been removed from 1.3.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Process
Hi,
The RichProcessFunction variant gives access to the functionality provided by
the RichFunction interface (e.g. allows overriding the `open` function
lifecycle method, access to the runtime context, etc.).
Whether or not to use it depends on your use case. You should be able to just
continue
with 1.3 what should we use for processFunction?
org.apache.flink.streaming.api.functions.RichProcessFunction
org.apache.flink.streaming.api.functions.ProcessFunction.{OnTimerContext,
Context}
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com
