Search code examples
pyflink

Why is there no RichMapFunction in pyflink?


There is pyflink.datastream.MapFunction in Flink Python API Docs. Meanwhile there is no RichMapFunction. Could somebody tell me why?


Solution

  • All the functions in PyFlink are rich. You can see that, pyflink.datastream.MapFunction extends pyflink.datastream.Function which has a open method.