PyFlink作业如何调用外部jar？

Question

我想在PyFlink作业中调用一个jar文件中的Java接口。在官方文档中没有找到解决方案。

Answer 1

在我看来，Flink 1.9中并不包含对这一功能的支持，而是正在进行的工作。请看 FLIP-58. FLIP-78 和 FLIP-88 可能也会有兴趣。请注意，这些改进大部分将包含在即将发布的Flink 1.10版本中。

Answer 2

如果满足你的需求，你可以使用python的table api来注册java用户定义的函数，方法的签名是register_java_function in table_environment。方法的签名是 register_java_function in table_environment。