I'd like to create a custom user-defined connector / source in pyflink. I see documentation for doing so in Java / Scala but none for Python. Is this possible?
No, that part of Flink's API is not available from Python.