0

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

4

2 回答 2

0

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

于 2020-02-05T10:15:27.250 回答
0

在我看来，Flink 1.9 中并未包含对此的支持，但仍在进行中。见FLIP-58。FLIP-78和FLIP-88也可能感兴趣。请注意，这些改进中的大部分将包含在即将发布的 Flink 1.10 版本中。

于 2020-01-06T12:55:51.867 回答