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.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With