Source code for Flink in Action - View it on GitHub