官术网_书友最值得收藏!

2.1.3 創(chuàng)建初始模板項(xiàng)目

在命令行中快速創(chuàng)建一個(gè)空白Flink項(xiàng)目,命令如下:

注意:如果要?jiǎng)?chuàng)建一個(gè)Java語言的空白Flink,則只需將上面構(gòu)建命令中的flink-quickstart-scala換成flink-quickstart-Java,其他操作都相同。

如果創(chuàng)建時(shí)很慢,則可以把http://repo1.maven.org/maven2/archetype-catalog.xml下載到本地倉庫根目錄,例如~/.m2下,并在執(zhí)行mvn archetype命令時(shí)加上參數(shù)-DarchetypeCatalog=internal。

這會(huì)在FlinkProjects目錄下創(chuàng)建一個(gè)Flink模板項(xiàng)目。在創(chuàng)建過程中,Maven會(huì)交互式地詢問groupId、artifactId和package名稱。這里筆者分別輸入以下名稱:

創(chuàng)建過程如圖2-8所示。

圖2-8 創(chuàng)建初始模板項(xiàng)目過程

工作目錄中將增加一個(gè)新目錄,目錄名稱是artifactId的名稱。在命令行中可以使用下面的命令查看項(xiàng)目結(jié)構(gòu):

項(xiàng)目結(jié)構(gòu)如圖2-9所示。

示例項(xiàng)目是一個(gè)Maven項(xiàng)目,它包含兩個(gè)類:StreamingJob和BatchJob,分別是DataStream和DataSet程序的基本框架程序。類中的main方法是程序的入口,用于內(nèi)部測試/執(zhí)行和部署。這個(gè)基本框架程序可以被導(dǎo)入IDE中進(jìn)行開發(fā)。

圖2-9 Flink Maven項(xiàng)目結(jié)構(gòu)

主站蜘蛛池模板: 绥德县| 五原县| 文成县| 招远市| 都安| 诸暨市| 邹平县| 茂名市| 波密县| 珲春市| 临海市| 苍山县| 垫江县| 绥中县| 土默特右旗| 泌阳县| 禹州市| 曲周县| 栾川县| 济南市| 郓城县| 邢台市| 峨眉山市| 武清区| 苏尼特右旗| 盱眙县| 孝义市| 云浮市| 桐城市| 禹城市| 手机| 桑日县| 满城县| 铅山县| 炉霍县| 富锦市| 岳普湖县| 吉隆县| 高安市| 砚山县| 铁岭县|