Scala API for Apache Beam and Google Cloud Dataflow
github.com