Code from an Apache Flink™ talk I regularly give - View it on GitHub