Flink系列文档脑图
由于源码分析系列文档较多,本人绘制了Flink文档脑图。和下面的文档目录对应。各位读者可以选择自己感兴趣的模块阅读并参与讨论。
此脑图不定期更新中……
文章目录
以下是本人Flink 源码分析系列文档目录,欢迎大家查阅和参与讨论。
如果需要转载,请务必注明出处。
Stream API:
Flink 源码之基本算子
Flink 源码之Window
Flink 源码之WindowOperator
Flink 源码之Trigger
Flink 源码之Continuous Trigger
Flink 源码之Evictor
Flink 源码之AsyncFunction
作业生成和调度:
Flink 源码之StreamGraph生成
Flink 源码之JobGraph生成
Flink 源码之ExecutionGraph
Flink 源码之OperatorChain
精准一次投送:
Flink 源码之快照
Flink 源码之两阶段提交
Flink 源码之分布式快照
Flink 源码之 1.11新特性Unaligned checkpoint
配置与优化:
Flink 源码之安全认证
时间处理:
Flink 源码之时间处理
架构:
Flink 源码之任务提交流程分析
Flink 源码之作业执行流程
Flink 源码之TaskManager启动流程
Flink 源码之内存管理
Flink 源码之节点间通信
Flink 源码之Credit Based反压
Flink 源码之leader选举(Zookeeper方式)
Flink 源码之 Slot
Flink 源码之StreamTask
Flink 源码之RPC调用
连接器:
Flink 源码之FlinkKafkaConsumer
Flink 源码之数据写入HBase
SQL:
Flink 源码之 SQL TableSource 和 TableSink
Flink 源码之 SQL 执行流程
源码技术点:
Java认证与授权 - JAAS
Java SPI 简介
Java 动态代理
CompletableFuture 使用示例
Java 注解的使用
Flink 使用介绍相关文档:
Flink 使用介绍相关文档目录
周边拓展:
Flink 源码周边之Maven Plugin