问为什么pyflink中没有RichMapFunction？
EN

Stack Overflow用户

提问于 2022-05-05 08:37:38

回答 2查看 55关注 0票数 0

Flink Python文档中有pyflink.datastream.MapFunction。同时不存在RichMapFunction。谁能告诉我原因吗？

回答已采纳

发布于 2022-05-07 03:15:45

PyFlink中的所有函数都很丰富。您可以看到，pyflink.datastream.MapFunction扩展了具有open方法的pyflink.datastream.Function。

票数 0

发布于 2022-05-05 15:50:04

我不知道为什么PyFlink缺少它，但是RichMapFunction是完全没有必要的。您可以用RichMapFunction做的任何事情都可以用ProcessFunction或KeyedProcessFunction来完成。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/72124262

复制

相似问题

问为什么pyflink中没有RichMapFunction？EN