有没有办法专门使用Python对flink作业进行分析?据我所知,表api将检索数据,我们只能使用api中的函数来转换数据。我是否遗漏或误解了文档中的任何内容?
发布于 2020-07-10 03: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
https://stackoverflow.com/questions/62648554
相似问题
领取专属 10元无门槛券
AI混元助手 在线答疑
洞察 腾讯核心技术
剖析业界实践案例