使用 Scala 编写 Beam 管道的官方 SDK 是 Scio.
Scio 是一个面向 Apache Beam 和 Google Cloud Dataflow 的 Scala API,灵感来自 Apache Spark 和 Scalding。Scio 旨在成为 Beam 之上的一个薄包装器,同时提供惯用的 Scala 风格 API。
了解更多关于 Scio 的信息 这里.