本文将向大家展示如何从头开始构建一个Flink开发项目。以下步骤主要针对MAC环境的操作,对于使用Windows系统的用户,请自行解决具体的环境配置问题。
在创建Maven项目之前,请确保已安装Java和Maven。可以通过执行以下命令来创建项目框架:
bash
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.xml
文件已经包含了开发Flink应用所需的基础依赖。
bash
$ tree
.
├── pom.xml
└── src
└── main
├── resources
│ └── log4j.properties
└── scala
└── com
└── yss
└── flink
├── BatchJob.scala
└── StreamingJob.scala
7 directories, 4 files
接下来,可以将Flink WordCount示例中的代码复制到项目中,并按照示例中的方法运行。