使用 Go SDK 开发的连接器的路线图。

• Go SDK 计划通过跨语言转换功能利用当前可用的 Java 和 Python 连接器。
  • 通过 Java 的 KafkaIO - 已完成
  • 通过 Java 的 BigQuery - 进行中
  • 通过 Java 的 Beam SQL
• Go SDK 支持有界管道上的 SplittableDoFns，因此可扩展的有界管道是可能的。
  • textio 包支持 ReadSdf 和 ReadAllSdf 用于高效批处理文本读取。
  • 将生成一个通用的 FileIO 以简化添加新的基于文件的连接器。