有没有专门使用python对flink作业进行分析的方法？据我所知，表api将检索数据，我们只能使用api中的函数来转换数据。我是否遗漏或误解了文档中的任何内容？
guz6ccqo1#
您可以定义自定义python udf或pandas udf来转换您可以引用的数据https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/python_udfs.html#user-定义的函数和https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/vectorized_python_udfs.html
1条答案
按热度按时间guz6ccqo1#
您可以定义自定义python udf或pandas udf来转换您可以引用的数据https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/python_udfs.html#user-定义的函数和https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/vectorized_python_udfs.html