在我们安装了flink 集群及使用flink自带的案例之后,我们就会涉及到真实的flink应用的开发了,所以从本文开始,我们来挨个介绍下flink 应用开发相关的系列。本文介绍使用maven模板创建一个基于Flink应用的java项目模板。
在一般的编辑器里面其实已经自带了flink的java模板,例如:
同时我们也可以使用maven命令来创建flink的模板,例如使用如下的命令:
mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-java -DarchetypeCatalog=https://repository.apache.org/content/repositories/snapshots/ -DarchetypeVersion=1.7.0
执行当前命令之后就可以看到正在下载maven相关的依赖:
然后我们等待执行完成。最后导入创建好的模板即可。
下面我们演示下使用Idea来创建一个flink的java项目模板,步骤如下:
1)打开idea
2)点击new project
3)填写相关的信息
4)添加archetype
点击这里的archetype
把上面的信息填写进去:
点击add
点击create按钮之后,这里的项目就开始创建了,同时开始下载对应的maven依赖:
等待依赖下载完毕之后,这里的项目模板就创建好了,如下图:
以上我们的flink java项目模板就创建好了。
通过模板创建的项目,会在默认的src目录下生成一个BatchJob和StreamingJob的任务:
这两个job,在后面我们所有的编程都是根据这两个job模板来开展的。
备注:
1、这里默认的flink版本是1.7.0,在实际中,我们需要修改成和实际使用环境一致的版本,例如:1.17.0,修改位置如下:
2、在项目里面,我们的artifactid和groupid会和我们的实际场景保持一致,这里默认是org.example,所以也需要修改一下:
最后附上我们本次创建的模板项目,登录后即可下载。
还没有评论,来说两句吧...