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