【问题标题】:Flink Python Custom Connector / SourceFlink Python 自定义连接器/源
【发布时间】:2020-11-26 05:21:57
【问题描述】:

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

【问题讨论】:

  • 为什么有人会否决这个?我已经完成了我的研究,没有资源清楚地解释这在 Python 中是否可行。因此,我必须得出结论,要么可能但没有记录,要么不可能,因此我向社区寻求帮助。
  • 嘿,同样的问题,你遇到过这个问题吗?
  • 我转而直接使用 JVM。

标签: java python apache-flink pyflink


【解决方案1】:

不,Flink 的那部分 API 不适用于 Python。

【讨论】:

  • 是否可以在 Scala 中制作自定义连接器,然后以某种方式将 py4j 桥接到 Python?
  • 我不太确定。我建议你在用户邮件列表中询问。
猜你喜欢
  • 2021-08-12
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2016-10-24
  • 1970-01-01
相关资源
最近更新 更多