Flink Python 自定义连接器/源

Flink Python Custom Connector / Source

我想在 pyflink 中创建自定义的用户定义连接器/源。我在 Java / Scala 中看到 documentation 这样做,但 Python 看到 none。这可能吗?

不,Flink API 的那部分在 Python 中不可用。