为什么pyflink中没有RichMapFunction？
Why is there no RichMapFunction in pyflink?
Flink Python API 文档中有pyflink.datastream.MapFunction。同时没有 RichMapFunction。谁能告诉我为什么？
我不确定为什么 PyFlink 中没有它，但是 RichMapFunction 是完全没有必要的。您可以使用 RichMapFunction 做的任何事情都可以使用 ProcessFunction 或 KeyedProcessFunction 来完成。
PyFlink的功能都很丰富。您可以看到，pyflink.datastream.MapFunction 扩展了 pyflink.datastream.Function，它有一个 open 方法。
Flink Python API 文档中有pyflink.datastream.MapFunction。同时没有 RichMapFunction。谁能告诉我为什么？
我不确定为什么 PyFlink 中没有它，但是 RichMapFunction 是完全没有必要的。您可以使用 RichMapFunction 做的任何事情都可以使用 ProcessFunction 或 KeyedProcessFunction 来完成。
PyFlink的功能都很丰富。您可以看到，pyflink.datastream.MapFunction 扩展了 pyflink.datastream.Function，它有一个 open 方法。