摘要:基于開(kāi)發(fā)指南本節(jié)主要介紹如何創(chuàng)建項(xiàng)目,并開(kāi)發(fā)簡(jiǎn)單的應(yīng)用,從而使該應(yīng)用可以被提交到平臺(tái)運(yùn)行。如果不設(shè)置為,可能會(huì)導(dǎo)致的類沖突,產(chǎn)生不可預(yù)見(jiàn)的問(wèn)題。在自動(dòng)生成的文件中,使用了來(lái)更方便的控制依賴的可見(jiàn)性。
本節(jié)主要介紹如何創(chuàng)建項(xiàng)目,并開(kāi)發(fā)簡(jiǎn)單的Fli
==== 自動(dòng)生成代碼框架 ==== 對(duì)于Java開(kāi)發(fā)者,可以使用maven自動(dòng)生成fli
mvn archetype:generate
-DarchetypeGroupId=org.apache.flink
-DarchetypeArtifactId=flink-quickstart-java
-DarchetypeVersion=1.6.4
對(duì)于scala開(kāi)發(fā)者,可以使用maven自動(dòng)生成fli
mvn archetype:generate
-DarchetypeGroupId=org.apache.flink
-DarchetypeArtifactId=flink-quickstart-scala
-DarchetypeVersion=1.6.4
在生成fli
如果想要自己創(chuàng)建Java項(xiàng)目,則需要手動(dòng)添加如下依賴:
org.apache.flink
flink-java
1.6.4
provided
org.apache.flink
flink-streaming-scala_2.11
1.6.4
provided
如果想要自己創(chuàng)建Scala項(xiàng)目,則需要手動(dòng)添加如下依賴:
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,因?yàn)閒link應(yīng)用在提交時(shí)會(huì)把這些依賴自動(dòng)添加到classpath中。如果不設(shè)置為provided,可能會(huì)導(dǎo)致Java的類沖突,產(chǎn)生不可預(yù)見(jiàn)的問(wèn)題。在自動(dòng)生成的pom文件中,使用了profile來(lái)更方便的控制fli nk依賴的可見(jiàn)性。使用maven打包后會(huì)生成兩個(gè)jar包,請(qǐng)使用不帶original前綴的jar包,因?yàn)樵摪腗ANIFEST.MF文件中不包含入口類信息。
實(shí)時(shí)文檔歡迎https://docs.ucloud.cn/ufli
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.specialneedsforspecialkids.com/yun/126202.html
摘要:基于開(kāi)發(fā)指南如果基于進(jìn)行應(yīng)用開(kāi)發(fā),需要在文件中加入如下配置注解注意修改的值,確保其符合您的應(yīng)用。應(yīng)用開(kāi)發(fā)完成后,可以直接直接運(yùn)行方法,在本地進(jìn)行基本的測(cè)試。基于gradle開(kāi)發(fā)指南如果基于gradle進(jìn)行應(yīng)用開(kāi)發(fā),需要在build.gradle文件中加入如下配置:buildscript { repositories { jcenter() // this applie...
摘要:開(kāi)發(fā)注意事項(xiàng)基于托管集群的應(yīng)用開(kāi)發(fā),和自建集群類似,但是仍然有幾個(gè)地方需要注意。和默認(rèn)配置托管集群默認(rèn)指定以及的堆大小為,目前不支持進(jìn)行更改單個(gè)中的數(shù)量設(shè)置為高可用配置應(yīng)用的高可用由集群以及共同保證。配置集群的運(yùn)行時(shí)狀態(tài)保存在的指定目錄中。UFlink開(kāi)發(fā)注意事項(xiàng)基于UFlink托管集群的Flink應(yīng)用開(kāi)發(fā),和自建集群類似,但是仍然有幾個(gè)地方需要注意。JobManager和TaskManag...
摘要:什么是實(shí)時(shí)計(jì)算實(shí)時(shí)計(jì)算基于構(gòu)建,為分布式高性能隨時(shí)可用以及準(zhǔn)確的流處理應(yīng)用程序提供流處理框架,可用于流式數(shù)據(jù)處理等應(yīng)用場(chǎng)景。版本支持當(dāng)前支持的版本為,,,可以在提交任務(wù)時(shí)選擇所使用的版本。什么是實(shí)時(shí)計(jì)算實(shí)時(shí)計(jì)算(UFlink)基于ApacheFlink構(gòu)建,為分布式、高性能、隨時(shí)可用以及準(zhǔn)確的流處理應(yīng)用程序提供流處理框架,可用于流式數(shù)據(jù)處理等應(yīng)用場(chǎng)景。產(chǎn)品優(yōu)勢(shì)100%開(kāi)源兼容基于開(kāi)源社區(qū)版本...
摘要:開(kāi)發(fā)指南是為簡(jiǎn)化計(jì)算模型,降低用戶使用實(shí)時(shí)計(jì)算的門(mén)檻而設(shè)計(jì)的一套符合標(biāo)準(zhǔn)語(yǔ)義的開(kāi)發(fā)套件。隨后,將為該表生成字段,用于記錄并表示事件時(shí)間。UFlink SQL 開(kāi)發(fā)指南UFlink SQL 是 UCloud 為簡(jiǎn)化計(jì)算模型,降低用戶使用實(shí)時(shí)計(jì)算的門(mén)檻而設(shè)計(jì)的一套符合標(biāo)準(zhǔn) SQL 語(yǔ)義的開(kāi)發(fā)套件。接下來(lái),開(kāi)發(fā)者可以根據(jù)如下內(nèi)容,逐漸熟悉并使用 UFlink SQL 組件所提供的便捷功能。1 ...
摘要:集群管理進(jìn)入集群管理頁(yè)面通過(guò)集群列表頁(yè)面進(jìn)入集群管理頁(yè)面獲取集群詳情通過(guò)集群列表的詳情按鈕進(jìn)入詳情頁(yè)面調(diào)整集群大小點(diǎn)擊調(diào)整容量調(diào)整集群大小查看點(diǎn)擊詳情頁(yè)的按鈕查看查看任務(wù)歷史點(diǎn)擊詳情頁(yè)的按鈕查看歷史任務(wù)節(jié)點(diǎn)密碼重置點(diǎn)擊集群列表頁(yè)的集群管理1. 進(jìn)入集群管理頁(yè)面通過(guò)UFlink集群列表頁(yè)面進(jìn)入集群管理頁(yè)面:2. 獲取集群詳情通過(guò)集群列表的詳情按鈕進(jìn)入詳情頁(yè)面:3. 調(diào)整集群大小點(diǎn)擊調(diào)整容量調(diào)整...
閱讀 3532·2023-04-25 20:09
閱讀 3736·2022-06-28 19:00
閱讀 3056·2022-06-28 19:00
閱讀 3075·2022-06-28 19:00
閱讀 3168·2022-06-28 19:00
閱讀 2874·2022-06-28 19:00
閱讀 3038·2022-06-28 19:00
閱讀 2632·2022-06-28 19:00