Start working on your Flink Scala program in a few simple steps.
#Requirements The only requirements are working Maven 3.0.4 (or higher) and Java 6.x (or higher) installations.
#Create Project Use one of the following commands to create a project:
#Inspect Project There will be a new directory in your working directory. If you've used the curl approach, the directory is called quickstart. Otherwise, it has the name of your artifactId.
The sample project is a Maven project, which contains a sample scala job that implements Word Count. Please note that the RunJobLocal and RunJobRemote objects allow you to start Flink in a development/testing mode.
We recommend to import this project into your IDE. For Eclipse, you need the following plugins, which you can install from the provided Eclipse Update Sites:
The IntelliJ IDE also supports Maven and offers a plugin for Scala development.
If you want to build your project, go to your project directory and issue themvn clean package command. You will find a jar that runs on every Flink cluster in target/flink-project-0.1-SNAPSHOT.jar.
#Next Steps
Write your application! If you have any trouble, ask on our Jira page (open an issue) or on our Mailing list. We are happy to provide help.