Example stream processing job, written in Scala with Apache Beam, for Google Cloud Dataflow - View it on GitHub