pyflink作业如何调用外部jar?

disbfnqx  于 2021-06-24  发布在  Flink
关注(0)|答案(2)|浏览(463)

我想在pyflink作业中调用jar文件中的java接口。在官方文件中找不到解决方案。

oyjwcjzk

oyjwcjzk1#

如果满足需要,可以使用python表api注册java自定义函数。方法的签名是表\环境中的register\ java\函数

pb3skfrl

pb3skfrl2#

在我看来,Flink1.9中并没有包含对这一点的支持,但仍在进行中。见flip-58。flip-78和flip-88可能也很有趣。请注意,这些改进中的大部分都将包含在即将发布的Flink1.10中。

相关问题