CODEWITHSUNDEEP
apache-flinkpyflink
Xingjun Wang
Xingjun Wang

Reputation: 423

How does a PyFlink job call external jar?

I want to call my Java interfaces in a jar file in a PyFlink job. No solutions are found in the offical document.

Upvotes: 0

Views: 939

Answers (2)

Xingbo Huang
Xingbo Huang

Reputation: 383

You can use python table api to register java user-defined function if it satisfies your need. The signature of method is register_java_function in table_environment

Upvotes: 0

David Anderson
David Anderson

Reputation: 43499

It looks to me like support for this was not included in Flink 1.9, but is ongoing work. See FLIP-58. FLIP-78 and FLIP-88 may also be of interest. Note that most of these improvements will be included in the upcoming Flink 1.10 release.

Upvotes: 0

Related Questions