我想在pyflink作业中调用jar文件中的java接口。在官方文件中找不到解决方案。
oyjwcjzk1#
如果满足需要,可以使用python表api注册java自定义函数。方法的签名是表\环境中的register\ java\函数
pb3skfrl2#
在我看来,Flink1.9中并没有包含对这一点的支持,但仍在进行中。见flip-58。flip-78和flip-88可能也很有趣。请注意,这些改进中的大部分都将包含在即将发布的Flink1.10中。
2条答案
按热度按时间oyjwcjzk1#
如果满足需要,可以使用python表api注册java自定义函数。方法的签名是表\环境中的register\ java\函数
pb3skfrl2#
在我看来,Flink1.9中并没有包含对这一点的支持,但仍在进行中。见flip-58。flip-78和flip-88可能也很有趣。请注意,这些改进中的大部分都将包含在即将发布的Flink1.10中。