flink-streaming-source-analysis
flink-streaming-source-analysis copied to clipboard
Published
20 hours ago •
mickey0524
mickey0524
flink 流处理源码分析
flink 流处理源码分析
目前社区内没有对 flink 流处理源码解析的文章，本 repo 的目标是全方位细致解析 flink 流处理的实现原理，加深大家对 flink 流式处理的认识
本 repo 分析的 flink 版本为 1.7.2，预计将会从几篇系列文章或方面来展开:
- flink 的安装
- 第一个 flink 流式处理小栗子
- 从源码角度简要分析一下 flink 流式处理小栗子
- flink 的 DataSource
- flink 的 DataSink
- flink DataStream 的转换
- flink KeyedStream 的转换
- flink 中的时间
- flink 中的 StreamPartitioner
- flink 中的异步操作符
- flink 中的定时器
- flink 的窗口 —— 窗口组件类
- flink 的窗口 —— 窗口操作符
- flink 的窗口 —— 窗口函数
- flink 的窗口 —— 窗口流
- flink DataStream 依托窗口完成的操作（coGroup、join）
- flink KeyedStream 的 intervalJoin
- flink 的架构和拓扑
- flink 的 StreamGraph
- flink 的 JobGraph
- flink 的 OperatorChain
- flink 的 RecordWriterOutput 和 RecordWriter
- flink 的 CheckpointBarrierHandler
- flink 的 StreamInputProcessor
- flink 的 StreamTask
- flink 的 Checkpoint
- flink 的 反压
- flink 的内存管理
- flink 的 Savepoint 和 Checkpoint 的区别
- 👇Under Construction🚧
- 博主是一名研二的学生，现在要暑期实习和准备秋招了，等待校招完毕，再来分享
org.apache.flink.runtime包
另外，在 flink-java-streaming-src 目录中有我对 flink 流式处理逐行代码的详细分析，大家有兴趣的可以看看
如果大家觉得本 repo 对您有所帮助，可以点个 star
mickey0524