Apache Beam Go SDK

Apache Beam 的 Go SDK 提供了一個簡單而強大的 API,用於建構批次和串流平行資料處理管道。它基於以下設計

與 Java 和 Python 不同,Go 是一種靜態編譯語言。這表示 worker 二進位檔可能需要交叉編譯才能在分散式執行器上執行。

開始使用 Go SDK

請從Beam Go SDK 快速入門開始,設定您的開發環境並執行範例管道。然後,請閱讀Beam 程式設計指南,以了解適用於 Beam 中所有 SDK 的基本概念。

請參閱 godoc 以取得更詳細的資訊。

狀態

2.32.0 版是 Go SDK 的最後一個實驗性版本。Go SDK 支援大多數以批次為導向的功能和跨語言轉換。它可以撰寫許多種類的轉換,但特定的內建轉換可能仍然缺失或不完整。

對於特定轉換的請求,可以提交到 GitHub Issues 中的 go 組件。歡迎貢獻。