Apache Beam Go SDK

Apache Beam 的 Go SDK 提供了一个简单而强大的 API,用于构建批处理和流式并行数据处理管道。它基于以下 设计

与 Java 和 Python 不同,Go 是一种静态编译语言。这意味着工作器二进制文件可能需要 交叉编译 才能在分布式运行器上执行。

Go SDK 入门

通过 Beam Go SDK 快速入门 开始使用,设置您的开发环境并运行示例管道。然后,阅读 Beam 编程指南 了解适用于 Beam 中所有 SDK 的基本概念。

查看 godoc 以获取更详细的信息。

状态

版本 2.32.0 是 Go SDK 的最后一个实验性版本。Go SDK 支持大多数面向批处理的功能和跨语言转换。可以编写许多类型的转换,但特定的内置转换可能仍然缺失或不完整。

有关特定转换的请求可以提交到 GitHub Issues 中的 go 组件。欢迎贡献。