gautamdudeja90 / flink-streaming-source-analysis

flink stream processing source code analysis

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

比较好的 flink 资料

• flink 中文文档
• 云邪的博客
• zhisheng的博客
• flink 流操作官方栗子