从零构建一个Flink项目(Scala版)
作者头像
  • 南京本地宝
  • 2019-10-20 14:12:06 3

本文将向大家展示如何从头开始构建一个Flink开发项目。以下步骤主要针对MAC环境的操作,对于使用Windows系统的用户,请自行解决具体的环境配置问题。

创建Maven项目

在创建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示例中的代码复制到项目中,并按照示例中的方法运行。

    本文来源:图灵汇
责任编辑: : 南京本地宝
声明:本文系图灵汇原创稿件,版权属图灵汇所有,未经授权不得转载,已经协议授权的媒体下载使用时须注明"稿件来源:图灵汇",违者将依法追究责任。
    分享
构建项目一个ScalaFlink
    下一篇