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?
Asked
Active
Viewed 417 times
5
-
Why would someone down-vote this? I've done my research, there is no resource clearly explaining if this is possible in Python, or not. I therefore must conclude that either it is possible and not documented, or it's not possible, thus I turn to the community for help. – Awesome-o Aug 06 '20 at 17:02
-
Hey, same problem, have you gotten anywhere with this? – MjBVala Dec 28 '20 at 01:33
-
I moved on to using the JVM directly instead. – Awesome-o Jan 04 '21 at 01:42
1 Answers
1
No, that part of Flink's API is not available from Python.
David Anderson
- 39,434
- 4
- 33
- 60
-
Would it be possible to make a custom connector in Scala and then somehow py4j bridge that over to Python? – Awesome-o Aug 06 '20 at 17:07
-
1I’m not entirely sure. I suggest you ask on the user mailing list. – David Anderson Aug 06 '20 at 17:14