有没有办法专门使用 Python 对 flink 作业进行分析？据我了解，table api将检索数据，我们只能使用api中的函数来转换数据。我是否遗漏或误解了文档中的任何内容？
问问题
53 次
1 回答
0
您可以定义自定义 Python UDF 或 Pandas UDF 来转换您的数据，您可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/python_udfs.html#用户定义函数和https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/vectorized_python_udfs.html
于 2020-07-10T03:29:28.070 回答