A Scala API for Google Cloud Dataflow and Apache Beam - View it on GitHub