Поддерживает ли Flink 1.2 Python в потоковом программировании?

Ссылка на онлайн-руководство по программированию на Python: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html Я не видел материалов, связанных с потоковым программированием, таких как коннектор kafka и т. д. .

Также из примеров хаба git (https://github.com/apache/flink/tree/master/flink-examples/flink-examples-streaming), кодов Python я тоже не видел.

Если он поддерживает Python в потоковом программировании, не могли бы вы показать мне несколько примеров для начала?

Спасибо!


person teddy    schedule 11.08.2017    source источник
comment
Существует открытый PR для добавления поддержки Python для потокового API: github.com/apache/flink/ pull / 3838 Я не совсем уверен, работает ли он в текущем состоянии, но это ваш лучший выбор.   -  person Chesnay Schepler    schedule 11.08.2017


Ответы (2)


Нет, Flink 1.2 не поддерживает Python для потоковой передачи. Flink 1.3 тоже его не поддерживает.

person Fabian Hueske    schedule 11.08.2017

Возможно, Flink 1.4 будет поддерживать Python для потоковой передачи, вы можете увидеть недавний PR FLINK-5886 - Python API для потоковые приложения.

person Hai Zhou    schedule 17.08.2017