天火燎原_e548

一.理解狀態(tài) 1.什么是狀態(tài) 其實(shí)是某一個時刻敷钾，計(jì)算的結(jié)果，一般是operator/task肄梨，保存在內(nèi)存阻荒，由于Flink分布式的運(yùn)行，所以根據(jù)體系結(jié)構(gòu)runtime众羡，會設(shè)計(jì)到...

天火燎原_e548

1.Connector是什么 2.Connector渠道 3.基于文件的預(yù)定義Source 4.基于Socket的預(yù)定于Source 5.基于Element和Collecti...

天火燎原_e548

1.什么是異步IO 侨赡，當(dāng)請求外部系統(tǒng)或者耗時操作，需要異步IO 2.AsyncDataStream 3.實(shí)現(xiàn)原理 有序 processing time無序 4.快照恢復(fù)

天火燎原_e548

1.概念 低階API process function粱侣，越底層越豐富復(fù)雜辆毡，提供了對狀態(tài)的管理中階API DataStream API，一般都是使用這個高級API ...

天火燎原_e548

1.join對比 cogroup相等于 left join,join 相等于 inner join甜害，connect可以不不相關(guān)的2個流連接起來interval join 范圍...

天火燎原_e548

一.Time 1.DataStream支持3種Time env.setStreamTimeCharacteristic(TimeCharacteristic.Processi...

天火燎原_e548

DataStream是Flink API中最核心的數(shù)據(jù)結(jié)構(gòu)尔店，代表一個運(yùn)行在多個分區(qū)上的并行流眨攘。 1.map&flatMap 2.filter 3.keyBy 4.KeyedS...

天火燎原_e548

1.git 下載源碼 git clonehttps://github.com/apache/flink.git 公司目前使用的是1.5.0版本鲫售，所以切換到release-1....

天火燎原_e548

一.Flink Runtime 1.運(yùn)行時架構(gòu) Client JobManager（master節(jié)點(diǎn)） TaskManager（Salve節(jié)點(diǎn)） 角色通信（Akka） 數(shù)據(jù)傳...