从零构建一个Flink项目(Scala版)

本文给大家演示一下如何从零搭建一个Flink开发项目。以下演示在MAC环境下进行，对于使用Windows的同学请自己解决具体的环境问题。

创建Maven项目

创建mvn项目前请安装好Java与Maven。在终端中执行以下命令即可创建项目骨架：

$ mvn archetype:generate \
    -DarchetypeGroupId=org.apache.flink \
    -DarchetypeArtifactId=flink-quickstart-scala \
    -DarchetypeVersion=1.7.0 \
    -DgroupId=com.yss.flink \
    -DartifactId=firstFlink \
    -Dversion=1.0 \
    -Dpackage=com.yss.flink \
    -DinteractiveMode=false

进入项目目录我们可以看一下maven生成的项目目录结构，其中pom文件已经包含了开发flink应用的基础依赖。

$ tree
.
├── pom.xml
└── src
    └── main
        ├── resources
        │   └── log4j.properties
        └── scala
            └── com
                └── yss
                    └── flink
                        ├── BatchJob.scala
                        └── StreamingJob.scala

7 directories, 4 files

然后我们可以将flink WordCount初体验中代码拷贝过来，并按其中的方式运行。