Apache Flink-導入Flink應用開發的模闆

進入Flink官網，選擇java版本的模闆

java版本模闆

執行

$ mvn archetype:generate                               \
  -DarchetypeGroupId=org.apache.flink              \
  -DarchetypeArtifactId=flink-quickstart-java      \
  -DarchetypeVersion=1.10.0
           

然後用idea打開目錄。

或者直接在idea中建立maven項目。然後選擇添加項目模闆

将上面的GAV資訊輸入進去就行。

項目build成功了之後

項目結構如下

• BachJob 批處理
• StreamJob 流處理

打開pom.xml檔案可以看到相關依賴。

建構項目指令

mvn clean package