HDFS写数据分析2020-07-13

1. 创建INodeFile流程分析 32.11

2步：
FSDataOutputStream focus——》FileSystem.create
focus.write（bytes[]）

抽象类 FSDataOutputStream.create
实现类 DistributedFileSystem.create

             ——》DFSClient.create
                         ——》DFSOutputStream.newStreamForCreate
                                  ——》dfsClient.namenode.create（远程代理类）
                                                               ↓  远程
                                          NamenodeRpcserver.create
                                         ——》（FSNamesystem）namesystem.startFile
                                                ——》FSNamesystem：startFileInt
                                                           —》FSNamesystem：startFileInternal
                                                                     —》（LeaseManager）leaseManager：addLease      租约

2. 添加契约流程分析 46.12

3. DataStreamer启动流程分析 56.11
4. 启动文件续约流程分析
5. 契约扫描机制分析
6. chunk写入DataQueue流程剖析
7. Block申请流程剖析 2.10
8. pipline数据管道流程建立分析 2.16
9. 管道建立容错处理 （retry ，排除问题机器） 2.45
10. ResponseProcessor组件初始化流程分析 3.00
11. BlockReceiver和PacketResponder初始化
12. 写数据层层上报处理结果 3.13
13. 写数据容错分析 3.20