發(fā)簡(jiǎn)信
IP屬地：江蘇
-
Flink(9)TransForm分組后聚合
keyBy 意思：分組之意。DataStream -> KeyedStream ： 邏輯的將一個(gè)流拆分成不相交的“分區(qū)”，每個(gè)分區(qū)包含相同的 k...
-
Flink(10) 支持的數(shù)據(jù)類型
簡(jiǎn)介 Flink 流應(yīng)用程序處理的是以數(shù)據(jù)對(duì)象表示的事件流，所有我們需要能夠處理這些對(duì)象，他們需要被序列化和反序列化，以便通過(guò)網(wǎng)絡(luò)傳遞他們，或者...
-
Flink(8) TransForm基本的轉(zhuǎn)換算子
基本轉(zhuǎn)換算子 1.mapmap 有映射的意思是把一個(gè)數(shù)據(jù)轉(zhuǎn)換成另一個(gè)的意思。（把小寫轉(zhuǎn)大些等）2.flatMapflat的意思是扁平的平坦的意思...
-
Flink(7) 自定義數(shù)據(jù)源
簡(jiǎn)介 只要實(shí)現(xiàn) SourceFunction 接口對(duì)應(yīng)的方法就可以自定義數(shù)據(jù)源1.創(chuàng)建環(huán)境 2.實(shí)現(xiàn) SourceFunction 接口
-
Flink(5)讀取數(shù)據(jù)源的幾種方式
執(zhí)行環(huán)境 創(chuàng)建一個(gè)執(zhí)行環(huán)境，表示當(dāng)前執(zhí)行程序的上下文，如果程序是獨(dú)立調(diào)用的則此方法返回本地執(zhí)行環(huán)境，如果從命令行客戶端調(diào)用程序提交到集群，則此方...
-
Flink(4)運(yùn)行時(shí)架構(gòu)Flink 運(yùn)行時(shí)的組建 作業(yè)管理器： JobManager 任務(wù)管理器： TaskManager 資源管理器：ResourceManager ...
-
Flink(3) 安裝和部署
下載 清華鏡像[https://mirrors.tuna.tsinghua.edu.cn/apache/] ,下載需要的版本 config/fi...
-
Flink(2) 簡(jiǎn)單上手
maven 依賴 Flink 批處理能力 Flink 流處理能力 2.啟動(dòng)設(shè)置 啟動(dòng)nc
-
Flink(1)簡(jiǎn)介簡(jiǎn)介 官網(wǎng)[https://flink.apache.org/zh/]，F(xiàn)link 是分布式大數(shù)據(jù)處理引擎，可對(duì)有限水流或無(wú)限數(shù)據(jù)流做有狀態(tài)或無(wú)...