开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >问答首页 >在Apache Flink中使用Python进行分析

问在Apache Flink中使用Python进行分析
EN

Stack Overflow用户

提问于 2020-06-30 08:27:35

回答 1查看 52关注 0票数 0

有没有办法专门使用Python对flink作业进行分析？据我所知，表api将检索数据，我们只能使用api中的函数来转换数据。我是否遗漏或误解了文档中的任何内容？

EN

回答 1

Stack Overflow用户

发布于 2020-07-10 11:29:28

您可以定义自定义Python UDF或Pandas UDF来转换您的数据，您可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/python_udfs.html#user-defined-functions和https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/vectorized_python_udfs.html

票数 0

EN

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

原文链接：

https://stackoverflow.com/questions/62648554

复制

相似问题