HDFS写细节02
2022-05-05 20:59:46 4 举报
hdfs文件写入流程源码细节②
作者其他创作
大纲/内容
循环直至关闭
demo.txt
不满足的小文件最后close时再刷
调用complete完成
请求新的Block & 初始化pipeline
写满block
512B切分为多个Chunk
完成关闭stream和流
No
response线程
关闭stream和流
write(bytes)
接受ACK
以4608B切分
DataStreamer线程
观察是否有packet发送
把packet入队
发送请求
写满126个
后台线程操作
写packet到pipeline中
Yes
循环调用write1()
0 条评论
回复 删除
下一页