本文給大家演示一下如何從零搭建一個(gè)Flink開發(fā)項(xiàng)目县钥。以下演示在MAC環(huán)境下進(jìn)行慈迈,對(duì)于使用Windows的同學(xué)請(qǐng)自己解決具體的環(huán)境問題若贮。
創(chuàng)建Maven項(xiàng)目
創(chuàng)建mvn項(xiàng)目前請(qǐng)安裝好Java與Maven省有。在終端中執(zhí)行以下命令即可創(chuàng)建項(xiàng)目骨架:
$ 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
進(jìn)入項(xiàng)目目錄我們可以看一下maven生成的項(xiàng)目目錄結(jié)構(gòu),其中pom文件已經(jīng)包含了開發(fā)flink應(yīng)用的基礎(chǔ)依賴谴麦。
$ tree
.
├── pom.xml
└── src
└── main
├── resources
│ └── log4j.properties
└── scala
└── com
└── yss
└── flink
├── BatchJob.scala
└── StreamingJob.scala
7 directories, 4 files
然后我們可以將flink WordCount初體驗(yàn)中代碼拷貝過來蠢沿,并按其中的方式運(yùn)行。