成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

【Flink實時計算 UFlink】基于Maven開發(fā)指南

Tecode / 2136人閱讀

摘要：基于開發(fā)指南本節(jié)主要介紹如何創(chuàng)建項目，并開發(fā)簡單的應用，從而使該應用可以被提交到平臺運行。如果不設置為，可能會導致的類沖突，產(chǎn)生不可預見的問題。在自動生成的文件中，使用了來更方便的控制依賴的可見性。

基于Maven開發(fā)指南

本節(jié)主要介紹如何創(chuàng)建項目，并開發(fā)簡單的Flink應用，從而使該Flink應用可以被提交到UFlink平臺運行。

==== 自動生成代碼框架 ==== 對于Java開發(fā)者，可以使用maven自動生成flink項目：

mvn archetype:generate                                  
      -DarchetypeGroupId=org.apache.flink            
      -DarchetypeArtifactId=flink-quickstart-java  
      -DarchetypeVersion=1.6.4

對于scala開發(fā)者，可以使用maven自動生成flink項目：

mvn archetype:generate                                  
      -DarchetypeGroupId=org.apache.flink            
      -DarchetypeArtifactId=flink-quickstart-scala  
      -DarchetypeVersion=1.6.4

在生成flink項目框架之后，請注意更改mainClass的值，使其符合您的應用。

手動配置maven項目

如果想要自己創(chuàng)建Java項目，則需要手動添加如下依賴：


  org.apache.flink
  flink-java
  1.6.4
  provided


  org.apache.flink
  flink-streaming-scala_2.11
  1.6.4
  provided

如果想要自己創(chuàng)建Scala項目，則需要手動添加如下依賴：


  org.apache.flink
  flink-scala_2.11
  1.6.4
  provided


  org.apache.flink
  flink-streaming-java_2.11
  1.6.4
  provided
注解:
此處的scope為provided，因為flink應用在提交時會把這些依賴自動添加到classpath中。如果不設置為provided，可能會導致Java的類沖突，產(chǎn)生不可預見的問題。在自動生成的pom文件中，使用了profile來更方便的控制flink依賴的可見性。使用maven打包后會生成兩個jar包，請使用不帶original前綴的jar包，因為該包的MANIFEST.MF文件中不包含入口類信息。

實時文檔歡迎https://docs.ucloud.cn/uflink/dev/maven

文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉載請注明本文地址：http://systransis.cn/yun/126202.html

相關文章

  • 【Flink實時計算 UFlink】基于gradle開發(fā)指南

    摘要：基于開發(fā)指南如果基于進行應用開發(fā)，需要在文件中加入如下配置注解注意修改的值，確保其符合您的應用。應用開發(fā)完成后，可以直接直接運行方法，在本地進行基本的測試?；趃radle開發(fā)指南如果基于gradle進行應用開發(fā)，需要在build.gradle文件中加入如下配置：buildscript { repositories { jcenter() // this applie...

    Tecode 評論0 收藏0

  • 【Flink實時計算 UFlink】UFlink開發(fā)注意事項

    摘要：開發(fā)注意事項基于托管集群的應用開發(fā)，和自建集群類似，但是仍然有幾個地方需要注意。和默認配置托管集群默認指定以及的堆大小為，目前不支持進行更改單個中的數(shù)量設置為高可用配置應用的高可用由集群以及共同保證。配置集群的運行時狀態(tài)保存在的指定目錄中。UFlink開發(fā)注意事項基于UFlink托管集群的Flink應用開發(fā)，和自建集群類似，但是仍然有幾個地方需要注意。JobManager和TaskManag...

    Tecode 評論0 收藏0

  • 【Flink實時計算 UFlink】什么是實時計算、產(chǎn)品優(yōu)勢、版本支持

    摘要：什么是實時計算實時計算基于構建，為分布式高性能隨時可用以及準確的流處理應用程序提供流處理框架，可用于流式數(shù)據(jù)處理等應用場景。版本支持當前支持的版本為，，，可以在提交任務時選擇所使用的版本。什么是實時計算實時計算（UFlink）基于ApacheFlink構建，為分布式、高性能、隨時可用以及準確的流處理應用程序提供流處理框架，可用于流式數(shù)據(jù)處理等應用場景。產(chǎn)品優(yōu)勢100%開源兼容基于開源社區(qū)版本...

    Tecode 評論0 收藏0

  • 【Flink實時計算 UFlink】UFlink SQL 開發(fā)指南

    摘要：開發(fā)指南是為簡化計算模型，降低用戶使用實時計算的門檻而設計的一套符合標準語義的開發(fā)套件。隨后，將為該表生成字段，用于記錄并表示事件時間。UFlink SQL 開發(fā)指南UFlink SQL 是 UCloud 為簡化計算模型，降低用戶使用實時計算的門檻而設計的一套符合標準 SQL 語義的開發(fā)套件。接下來，開發(fā)者可以根據(jù)如下內容，逐漸熟悉并使用 UFlink SQL 組件所提供的便捷功能。1 ...

    Tecode 評論0 收藏0

  • 【Flink實時計算 UFlink】集群管理

    摘要：集群管理進入集群管理頁面通過集群列表頁面進入集群管理頁面獲取集群詳情通過集群列表的詳情按鈕進入詳情頁面調整集群大小點擊調整容量調整集群大小查看點擊詳情頁的按鈕查看查看任務歷史點擊詳情頁的按鈕查看歷史任務節(jié)點密碼重置點擊集群列表頁的集群管理1. 進入集群管理頁面通過UFlink集群列表頁面進入集群管理頁面：2. 獲取集群詳情通過集群列表的詳情按鈕進入詳情頁面：3. 調整集群大小點擊調整容量調整...

    Tecode 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<