Использование Python в Apache Flink для аналитики

Question

Есть ли способ делать аналитику по флинк-заданиям, используя Python? Насколько я понимаю, api таблицы будет извлекать данные, и мы можем использовать только функции в api для преобразования данных. Я что-то пропустил или неправильно понял в документации?

Answer 1

Вы можете определить пользовательский Python UDF или Pandas UDF для преобразования ваших данных, на которые вы можете ссылаться https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/python_udfs.html и https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/python/vectorized_python_udfs.html