Apache Beam Scala SDK

Scala で Beam パイプラインを作成するための公式 SDK は Scio です。

Scio

Scio は、Apache Spark と Scalding に触発された Apache Beam および Google Cloud Dataflow 用の Scala API です。Scio は、慣用的な Scala スタイルの API を提供しながら、Beam の上に薄いラッパーとして存在することを目指しています。

Scio の詳細については、こちらをご覧ください。