Real time data processing system based on flink and CEP - View it on GitHub