? ? ? ??Flink是Apache軟件基金會下開源的分布式流批一體計算框架,具備實時流計算和高吞吐批處理計算的大數據計算能力。本專欄內容為Flink源碼解析的記錄與分享。
? ? ? ? 本文解析的Flink源碼版本為:flink-1.19.0
? ? ? ? 以下為Flink-1.19.0-完整源碼詳解的目錄導航。
Flink-1.19.0-完整源碼詳解:
1.《《Flink-1.19.0源碼詳解1-Flink各級調度核心原理與源碼解析》(重點)
2.《Flink-1.19.0源碼詳解2-Flink CliFrontend客戶端啟動源碼解析》
3.《Flink-1.19.0源碼詳解3-Flink DataStream數據流轉換為Transformation集合源碼解析》
4.《Flink-1.19.0源碼詳解4-StreamGraph生成》(重點)
5.《Flink-1.19.0源碼詳解5-JobGraph生成-前篇》(重點)
6.《Flink-1.19.0源碼詳解6-JobGraph生成-后篇》(重點)
7.《Flink-1.19.0源碼詳解7-Flink集群端調度》
8.《Flink-1.19.0源碼詳解8-ExecutionGraph生成-前篇》(重點)
9.《Flink-1.19.0源碼詳解9-ExecutionGraph生成-后篇》(重點)
10.《Flink-1.19.0源碼詳解10-Flink計算資源的申請與調度》
11.《Flink-1.19.0源碼詳解11-Flink ResourceManager資源調度》
持續更新中...
Flink-1.19.0-源碼解析補充說明內容:
1.《Flink-1.19.0源碼詳解-番外補充1-Flink on Yarn的三種部署模式解析》
2.《Flink-1.19.0源碼詳解-番外補充2-算子的定義與執行解析》
3.《Flink-1.19.0源碼詳解-番外補充3-StreamGraph圖》
4.《Flink-1.19.0源碼詳解-番外補充4-JobGraph圖》
持續更新中...
Kafka3.8.0-完整源碼詳解:
1.《Kafka-3.8.0源碼詳解1-Kafka生產者核心原理解析》
2.《Kafka-3.8.0源碼詳解2-Kafka生產者及其核心組件啟動源碼解析》
3.《Kafka-3.8.0源碼詳解3-Kafka生產者消息生產源碼詳解》
4.《Kafka-3.8.0源碼詳解4-Kafka生產者數據發送源碼詳解》
5.《Kafka-3.8.0源碼詳解5-Kafka生產者配置詳解與拓展調優》
持續更新中...