从零构建一个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.scala7 directories, 4 files

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