keyBy 意思:分組之意内列。DataStream -> KeyedStream : 邏輯的將一個流拆分成不相交的“分區(qū)”,每個分區(qū)包含相同的 key元素引有,在內(nèi)部以 hash ...
![240](https://cdn2.jianshu.io/assets/default_avatar/5-33d2da32c552b8be9a0548c7a4576607.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
keyBy 意思:分組之意内列。DataStream -> KeyedStream : 邏輯的將一個流拆分成不相交的“分區(qū)”,每個分區(qū)包含相同的 key元素引有,在內(nèi)部以 hash ...
簡介 Flink 流應(yīng)用程序處理的是以數(shù)據(jù)對象表示的事件流细层,所有我們需要能夠處理這些對象惜辑,他們需要被序列化和反序列化,以便通過網(wǎng)絡(luò)傳遞他們疫赎,或者從狀態(tài)后端盛撑,檢查點,和保存點讀...
基本轉(zhuǎn)換算子 1.mapmap 有映射的意思是把一個數(shù)據(jù)轉(zhuǎn)換成另一個的意思捧搞。(把小寫轉(zhuǎn)大些等)2.flatMapflat的意思是扁平的平坦的意思抵卫。和map 結(jié)合是把數(shù)據(jù)平坦展...
簡介 只要實現(xiàn) SourceFunction 接口對應(yīng)的方法就可以自定義數(shù)據(jù)源1.創(chuàng)建環(huán)境 2.實現(xiàn) SourceFunction 接口
執(zhí)行環(huán)境 創(chuàng)建一個執(zhí)行環(huán)境,表示當(dāng)前執(zhí)行程序的上下文胎撇,如果程序是獨立調(diào)用的則此方法返回本地執(zhí)行環(huán)境介粘,如果從命令行客戶端調(diào)用程序提交到集群,則此方法返回此集群的執(zhí)行環(huán)境晚树,也就是...
Flink 運行時的組建 作業(yè)管理器: JobManager 任務(wù)管理器: TaskManager 資源管理器:ResourceManager 分發(fā)器:Dispacher 作...
下載 清華鏡像[https://mirrors.tuna.tsinghua.edu.cn/apache/] ,下載需要的版本 config/fink-conf.yaml st...
簡介 官網(wǎng)[https://flink.apache.org/zh/]姻采,F(xiàn)link 是分布式大數(shù)據(jù)處理引擎,可對有限水流或無限數(shù)據(jù)流做有狀態(tài)或無狀態(tài)對計算爵憎,能夠部署在各種集群...
下載地址 Go官網(wǎng)下載地址:https://golang.org/dl/[https://golang.org/dl/] Go官方鏡像站(推薦):https://golang...
go module go module 是Go1.11版本之后官方推出的版本管理工具慨亲。并且從Go1.13版本開始婚瓜,go module 將成 Go語言默認的依賴管理工具。 官方...
vagrant ssh-config 結(jié)果 更改源: 安裝 ansible 修改配置 ansible.cfg 被控主機清單 參考:https://zhuanlan.zhihu...
簡介 當(dāng)ansible執(zhí)行腳本需要root權(quán)限的時候刑棵,我們用become功能 官方參考文檔: become 文檔[https://docs.ansible.com/ansib...
問題 當(dāng)某個軟件如java安裝在某個用戶下,軟件的環(huán)境變量放在 ~/.bash_profile 或 ~/.zshrc .SSH 遠程執(zhí)行腳本報錯"command not fo...
簡介 ansible是新出現(xiàn)的自動化運維工具巴刻,急于python開發(fā)。實現(xiàn)了批量系統(tǒng)配置蛉签,批量程序部署胡陪,批量運行命令等,特性:部署簡單:基于python和ssh,安全基于:Op...
簡介:安裝 elasticsearch 版本是6.8.0 正蛙,ubuntu環(huán)境 下載 到華為云鏡像 首先安裝java 環(huán)境 安裝es 修改配置文件 修改系統(tǒng)的參數(shù) 啟動 添加s...
http 協(xié)議 http 協(xié)議是一個用于傳輸超媒體文檔(例如html)的應(yīng)用層的協(xié)議督弓。他是為了web瀏覽器和web 服務(wù)器之間的通訊而設(shè)計的可以參考:MDN web Docs...
簡介 大部分的情況我們的代碼的執(zhí)行都是按照代碼的調(diào)用順序來從頭執(zhí)行到尾。打印出線程的名字是http-nio-8080-exec-x 某個線程乒验。在我們執(zhí)行異步任務(wù)的時候需要創(chuàng)建...
簡介 攔截器是spring中的概念和過濾器類似愚隧,都可以處理請求和相應(yīng)。但對過濾器而言锻全,它更處理對更細致些狂塘,可以從三個方向進行攔截處理。 perHandle 在控制器訪問之前執(zhí)...
1.java異常 java中的異出幔可是是函數(shù)中的語句引發(fā)的荞胡,也可以是通過 throw 顯示的拋出去的。只要java中有異常了嚎,就會有一個對應(yīng)的異常對象來封裝這個類泪漂。JRE就會試...