Flink 源码分析系列文档目录
Flink系列文档脑图
由于源码分析系列文档较多,本人绘制了Flink文档脑图。和下面的文档目录对应。各位读者可以选择自己感兴趣的模块阅读并参与讨论。
![](https://img.haomeiwen.com/i6645072/98a75575f4eceb47.png)
此脑图不定期更新中……
文章目录
以下是本人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 源码之任务提交流程分析
Flink 源码之作业执行流程
Flink 源码之TaskManager启动流程
Flink 源码之内存管理
Flink 源码之节点间通信
Flink 源码之Credit Based反压
Flink 源码之leader选举(Zookeeper方式)
Flink 源码之 Slot
Flink 源码之StreamTask
Flink 源码之RPC调用
Flink 源码之新 Source 架构
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 Hudi:
Flink Hudi 源码之HoodieTableSink
Flink Hudi 源码之COW表数据写入流程
源码技术点:
Java认证与授权 - JAAS
Java SPI 简介
Java 动态代理
CompletableFuture 使用示例
Java 注解的使用
Flink 使用介绍相关文档:
周边拓展: