Я хотел бы создать пользовательский коннектор / источник в pyflink. Я вижу документацию для этого в Java / Scala, но не для Python. Возможно ли это?
Нет, эта часть API Flink недоступна из Python.