KeyedProcessFunction

[Maminspapin]

Hello,

I'm learning State Processor API:
https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html

There is example in this page with StatefulFunctionWithTime extends
KeyedProcessFunction. And here we can see method open() we need implement to
initialize state. But when I try KeyedProcessFunction abstract class in my
code there is no method open().

Using Flink 1.12.

What's wrong I do?

Thanks.
Yuri L.




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Maminspapin]

I missed in documentation:

A KeyedProcessFunction is always a RichFunction. Therefore, access to the
RuntimeContext is always available and setup and teardown methods can be
implemented. See
RichFunction.open(org.apache.flink.configuration.Configuration) and
RichFunction.close().

https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/functions/KeyedProcessFunction.html



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/