【发布时间】:2020-11-26 05:21:57
【问题描述】:
我想在 pyflink 中创建一个自定义的用户定义的连接器/源。我看到documentation 在 Java / Scala 中这样做,但在 Python 中没有。这可能吗?
【问题讨论】:
-
为什么有人会否决这个?我已经完成了我的研究,没有资源清楚地解释这在 Python 中是否可行。因此,我必须得出结论,要么可能但没有记录,要么不可能,因此我向社区寻求帮助。
-
嘿,同样的问题,你遇到过这个问题吗?
-
我转而直接使用 JVM。
标签: java python apache-flink pyflink