有没有办法专门使用 Python 对 flink 作业进行分析?据我了解,表 api 将检索数据,我们只能使用 api 中的函数来转换数据。我是否遗漏或误解了文档中的任何内容?
您可以定义自定义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