Flink系列文檔腦圖
由于源碼分析系列文檔較多洒缀,本人繪制了Flink文檔腦圖。和下面的文檔目錄對(duì)應(yīng)欺冀。各位讀者可以選擇自己感興趣的模塊閱讀并參與討論树绩。
此腦圖不定期更新中……
文章目錄
以下是本人Flink 源碼分析系列文檔目錄,歡迎大家查閱和參與討論脚猾。
如果需要轉(zhuǎn)載葱峡,請(qǐng)務(wù)必注明出處。
Stream API:
Flink 源碼之基本算子
Flink 源碼之Window
Flink 源碼之WindowOperator
Flink 源碼之Trigger
Flink 源碼之Continuous Trigger
Flink 源碼之Evictor
Flink 源碼之AsyncFunction
Flink 源碼之 Side Output 踩坑
Flink 源碼之異步state API
作業(yè)生成和調(diào)度:
Flink 源碼之StreamGraph生成
Flink 源碼之JobGraph生成
Flink 源碼之ExecutionGraph
Flink 源碼之OperatorChain
Flink 源碼之?dāng)?shù)據(jù)分區(qū)
Flink 源碼之batch問題處理
精準(zhǔn)一次投送:
Flink 源碼之快照
Flink 源碼之兩階段提交
Flink 源碼之分布式快照
Flink 源碼之 1.11新特性Unaligned checkpoint
配置與優(yōu)化:
Flink 源碼之安全認(rèn)證
Flink 源碼之Buffer Debloating
Flink 源碼之 Buffer Timeout優(yōu)化
Flink 源碼之 Window Slice
時(shí)間處理:
Flink 源碼之時(shí)間處理
Flink 使用之WatermarkStrategy(含源碼分析)
架構(gòu):
Flink 源碼之任務(wù)提交流程分析
Flink 源碼之作業(yè)執(zhí)行流程
Flink 源碼之TaskManager啟動(dòng)流程
Flink 源碼之內(nèi)存管理
Flink 源碼之節(jié)點(diǎn)間通信
Flink 源碼之Credit Based反壓
Flink 源碼之leader選舉(Zookeeper方式)
Flink 源碼之 Slot
Flink 源碼之StreamTask
Flink 源碼之RPC調(diào)用
Flink 源碼之新 Source 架構(gòu)
Flink 源碼之 KafkaSource
Flink 源碼之 KafkaSink
Flink 源碼之 yarn-session 啟動(dòng)流程
Flink 源碼之 Distributed Cache
連接器:
Flink 源碼之FlinkKafkaConsumer
Flink 源碼之?dāng)?shù)據(jù)寫入HBase
SQL:
Flink 源碼之 SQL TableSource 和 TableSink
Flink 源碼之 SQL 執(zhí)行流程
Flink 源碼之 SQL 內(nèi)置function定義方式
Flink 源碼之 Table early fire 和 late fire
Flink 源碼之 LookupTableSource
Flink Hudi:
Flink Hudi 源碼之HoodieTableSink
Flink Hudi 源碼之COW表數(shù)據(jù)寫入流程
源碼技術(shù)點(diǎn):
Java認(rèn)證與授權(quán) - JAAS
Java SPI 簡介
Java 動(dòng)態(tài)代理
CompletableFuture 使用示例
Java 注解的使用
Flink 使用介紹相關(guān)文檔:
周邊拓展: