An Apache Samza stream processing job written in Scala - View it on GitHub