There is pyflink.datastream.MapFunction in Flink Python API Docs. Meanwhile there is no RichMapFunction. Could somebody tell me why?
All the functions in PyFlink are rich. You can see that, pyflink.datastream.MapFunction
extends pyflink.datastream.Function
which has a open
method.