Как задание PyFlink вызывает внешнюю банку?

Question

Я хочу вызвать свои интерфейсы Java в файле jar в задании PyFlink. В официальном документе решений не найдено.

Answer 1

Вы можете использовать python table api для регистрации пользовательской функции Java, если она удовлетворяет ваши потребности. Сигнатура метода - register_java_function в table_environment

Answer 2

Мне кажется, что поддержка этого не была включена в Flink 1.9, но работа продолжается. См. FLIP-58. Также могут быть интересны FLIP-78 и FLIP-88. Обратите внимание, что большинство этих улучшений будет включено в грядущий выпуск Flink 1.10.