A lightweight library intended to make developing Google DataFlow jobs in Scala easier. - View it on GitHub