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

2.2.1 在IntelliJ IDEA中創(chuàng)建Flink項(xiàng)目

要在IntelliJ IDEA中創(chuàng)建Flink Maven項(xiàng)目,建議按以下步驟操作:

(1)啟動(dòng)IntelliJ IDEA,創(chuàng)建一個(gè)新的項(xiàng)目,如圖2-12所示。

圖2-12 在IntelliJ IDEA中創(chuàng)建一個(gè)新的項(xiàng)目

(2)選擇Maven項(xiàng)目,并選擇Create from archetype,如圖2-13所示。

(3)因?yàn)槟J(rèn)沒有Flink的archetype,所以需要自己添加。

添加flink-quickstart-java的archetype,如圖2-14所示。

添加flink-quickstart-scala的archetype,如圖2-15所示。

圖2-13 選擇Maven項(xiàng)目,并勾選Create from archetype項(xiàng)

圖2-14 添加flink-quickstart-java的archetype

(4)選擇對應(yīng)的archetype,例如,這里選擇flink-quickstart-scala,如圖2-16所示。

(5)指定項(xiàng)目的groupId、artifactId名稱。這里分別取以下名稱:

如圖2-17所示。

圖2-15 添加flink-quickstart-scala的archetype

圖2-16 選擇項(xiàng)目模板

圖2-17 指定項(xiàng)目的groupId、artifactId名稱

(6)接下來,指定項(xiàng)目的Maven配置,此處可采用默認(rèn)配置,如圖2-18所示。

圖2-18 指定項(xiàng)目的Maven配置

(7)指定項(xiàng)目的名稱和項(xiàng)目文件所在位置。這里保持默認(rèn)配置即可。單擊Finish按鈕,開始創(chuàng)建項(xiàng)目,如圖2-19所示。

圖2-19 指定項(xiàng)目的名稱和項(xiàng)目文件所在位置

(8)Maven會自動(dòng)構(gòu)建項(xiàng)目,最后的項(xiàng)目結(jié)構(gòu)如圖2-20所示。

可以看出,flink-quickstart-scala快速地構(gòu)建了一個(gè)基本的Flink項(xiàng)目框架,并創(chuàng)建了兩個(gè)模板程序文件:用于流處理的StreamingJob和用于批處理的BatchJob。

注意:以同樣的步驟,選擇flink-quickstart-java,創(chuàng)建一個(gè)基于Java API的Flink項(xiàng)目框架。讀者可自行嘗試。

圖2-20 最終生成的項(xiàng)目結(jié)構(gòu)

主站蜘蛛池模板: 榕江县| 维西| 闵行区| 东乌珠穆沁旗| 石棉县| 孟州市| 武威市| 凤山县| 渭源县| 德钦县| 科技| 莱芜市| 兴化市| 商丘市| 兴仁县| 定州市| 兴山县| 屏东市| 门头沟区| 边坝县| 安阳市| 伊春市| 龙陵县| 宁化县| 大竹县| 黄浦区| 昌宁县| 施秉县| 蒲江县| 库尔勒市| 盐津县| 綦江县| 芷江| 潜山县| 揭阳市| 甘泉县| 藁城市| 晋中市| 恩平市| 望奎县| 娄烦县|