Demo quering counts of a event stream with Apache Flink - View it on GitHub