我想在 PyFlink 作业的 jar 文件中调用我的 Java 接口。在正式文件中找不到解决方案。
在我看来,Flink 1.9 中没有包含对此的支持,但正在进行中。参见 FLIP-58。FLIP-78 和 FLIP-88 也可能令人感兴趣。请注意,这些改进中的大多数将包含在即将发布的 Flink 1.10 版本中。
您可以使用python表api来注册java用户定义的函数,如果它满足你的需要。方法的签名register_java_function table_environment