# flink-source-zh

**Repository Path**: dhd_index/flink-source-zh

## Basic Information

- **Project Name**: flink-source-zh
- **Description**: Flink源码阅读分享，不断记录Flink源码的阅读过程
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2022-03-04
- **Last Updated**: 2022-03-04

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Flink源码阅读目录：

* [Flink源码阅读1：任务提交](../master/doc/jobsubmit.md)

* [Flink源码阅读2：数据传递](../master/doc/datadeliver.md)

* [Flink源码阅读3：StreamOperator](../master/doc/streamoperator.md)

* [Flink源码阅读4：StreamTask](../master/doc/streamtask.md)

* [Flink源码阅读5：Java泛型类型擦除和Flink类型暗示](../master/doc/typeerasureandtypehint.md)

* [Flink源码阅读6：两阶段提交](../master/doc/2pc.md)

* [Flink源码阅读7：分布式快照](../master/doc/chandylamport.md)

* [Flink源码阅读8：窗口触发器](../master/doc/triggerandevictor.md)

* [Flink源码阅读9：流分区器](../master/doc/partitioner.md)

* [Flink源码阅读10：定时器](../master/doc/timer.md)

* [Flink源码阅读11：IO模型及Flink中的异步IO](../master/doc/nio.md)

* [Flink源码阅读12：背压](../master/doc/backpressure.md)

* [Flink源码阅读13：Source和Sink](../master/doc/sourceandsink.md)

* [Flink源码阅读14：内存管理](../master/doc/memory.md)

* [Flink源码阅读15：窗口Window](../master/doc/window.md)

* [Flink源码阅读16：Flink数据通信](../master/doc/conn.md)

* [Flink源码阅读17：FlinkKafkaConsumer](../master/doc/flinkkafkaconsumer.md)

* [Flink源码阅读18：事件时间和水位线](../master/doc/eventtimeandwatermark.md)

* [Flink源码阅读19：State存储](../master/doc/statestore.md)

* [Flink源码阅读20：Flink SQL](../master/doc/sql.md)

* [Flink源码阅读21：调度器](../master/doc/scheduler.md)

* [Flink源码阅读22：类加载](../master/doc/loadclass.md)

### 扩展阅读

* [Flink扩展阅读1：全链路延迟测量](../master/doc/latency.md)

* [Flink扩展阅读2：分布式系统中的CAP和BASE理论](../master/doc/capandbase.md)

* [Flink扩展阅读3：分布式共识算法Raft](../master/doc/raft.md)

* [Flink扩展阅读4：数据去重](../master/doc/datadeduplication.md)

* [Flink扩展阅读5：问题实战](../master/doc/thinking.md)

* [Flink扩展阅读6：数据仓库](../master/doc/realtimedatawarehouse.md)

* [Flink扩展阅读7：Java SPI](../master/doc/spi.md)