Flink7：Flink流處理Api之Environment

流處理基本步驟：


Environment
  1. getExecutionEnvironment創(chuàng)建
    創(chuàng)建一個執(zhí)行環(huán)境，表示當(dāng)前執(zhí)行程序的上下文。 如果程序是獨立調(diào)用的，則此方法返回本地執(zhí)行環(huán)境；如果從命令行客戶端調(diào)用程序以提交到集群，則此方法返回此集群的執(zhí)行環(huán)境，也就是說，getExecutionEnvironment會根據(jù)查詢運行的方式?jīng)Q定返回什么樣的運行環(huán)境，是最常用的一種創(chuàng)建執(zhí)行環(huán)境的方式。 
val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment

如果沒有設(shè)置并行度，會以flink-conf.yaml中的配置為準(zhǔn)，默認(rèn)是1


  1. createLocalEnvironment創(chuàng)建
    返回本地執(zhí)行環(huán)境，需要在調(diào)用時指定默認(rèn)的并行度。
val env = StreamExecutionEnvironment.createLocalEnvironment(1)
  1. createRemoteEnvironment創(chuàng)建
    返回集群執(zhí)行環(huán)境，將Jar提交到遠(yuǎn)程服務(wù)器。需要在調(diào)用時指定JobManager的IP和端口號，并指定要在集群中運行的Jar包。
val env = ExecutionEnvironment.createRemoteEnvironment("jobmanager-hostname", 6123,"C://jar//flink//wordcount.jar")
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容