Flink系列文檔腦圖
由于源碼分析系列文檔較多,本人繪制了Flink文檔腦圖。和下面的文檔目錄對應。各位讀者可以選擇自己感興趣的模塊閱讀并參與討論。
此腦圖不定期更新中……
文章目錄
以下是本人Flink 源碼分析系列文檔目錄,歡迎大家查閱和參與討論。
如果需要轉載,請務必注明出處。
Stream API:
Flink 源碼之基本算子
Flink 源碼之Window
Flink 源碼之WindowOperator
Flink 源碼之Trigger
Flink 源碼之Continuous Trigger
Flink 源碼之Evictor
Flink 源碼之AsyncFunction
Flink 源碼之 Side Output 踩坑
作業生成和調度:
Flink 源碼之StreamGraph生成
Flink 源碼之JobGraph生成
Flink 源碼之ExecutionGraph
Flink 源碼之OperatorChain
Flink 源碼之數據分區
Flink 源碼之batch問題處理
精準一次投送:
Flink 源碼之快照
Flink 源碼之兩階段提交
Flink 源碼之分布式快照
Flink 源碼之 1.11新特性Unaligned checkpoint
配置與優化:
Flink 源碼之安全認證
Flink 源碼之Buffer Debloating
Flink 源碼之 Buffer Timeout優化
Flink 源碼之 Window Slice
時間處理:
Flink 源碼之時間處理
Flink 使用之WatermarkStrategy(含源碼分析)
架構:
Flink 源碼之任務提交流程分析
Flink 源碼之作業執行流程
Flink 源碼之TaskManager啟動流程
Flink 源碼之內存管理
Flink 源碼之節點間通信
Flink 源碼之Credit Based反壓
Flink 源碼之leader選舉(Zookeeper方式)
Flink 源碼之 Slot
Flink 源碼之StreamTask
Flink 源碼之RPC調用
Flink 源碼之新 Source 架構
Flink 源碼之 KafkaSource
Flink 源碼之 KafkaSink
Flink 源碼之 yarn-session 啟動流程
Flink 源碼之 Distributed Cache
連接器:
Flink 源碼之FlinkKafkaConsumer
Flink 源碼之數據寫入HBase
SQL:
Flink 源碼之 SQL TableSource 和 TableSink
Flink 源碼之 SQL 執行流程
Flink 源碼之 SQL 內置function定義方式
Flink 源碼之 Table early fire 和 late fire
Flink 源碼之 LookupTableSource
Flink Hudi:
Flink Hudi 源碼之HoodieTableSink
Flink Hudi 源碼之COW表數據寫入流程
源碼技術點:
Java認證與授權 - JAAS
Java SPI 簡介
Java 動態代理
CompletableFuture 使用示例
Java 注解的使用
Flink 使用介紹相關文檔:
Flink 使用介紹相關文檔目錄
周邊拓展:
Flink 源碼周邊之Maven Plugin
Flink 源碼分析系列文檔目錄 - 簡書 (jianshu.com)
作者:AlienPaul
鏈接:https://www.jianshu.com/p/d4a372809e3d
來源:簡書
著作權歸作者所有。商業轉載請聯系作者獲得授權,非商業轉載請注明出處。