Можно ли использовать PyFlink с python библиотеками машинного обучения, такими как LightGBM, для потокового приложения? Есть ли хороший пример для этого?
Полного примера нет, но вы можете взять лут на Начало работы с Flink Python, а затем посмотреть, как можно использовать Python UDF: UDF в таблице API .