This repository has examples for Apache flink. Build sbt clean package Running Load the project into eclipse or IntelliJ to run