写流程write方法DataNode端
2021-09-15 09:36:54 1 举报写流程create方法NameNode端
作者其他创作
大纲/内容
receiveBlock
start
DataXceiver
对client的数据进行确认
int
BlockOpResponseProto .writeDelimitedTo(replyOut);
accept
sendAckUpstream
Sender(mirrorOut).writeBlock
ack.readFields(downstreamIn)
DataXceiverServer
enqueue
如果不是最后一个datanode，直接加入队列
checksumOut.write
removeAckHead
ackQueue
create
Client
DataNode2
mirrorOut = new DataOutputStream
Receiver
此时序图所描述的是第一个DataNode
writeBlock
receivePacket
out.writ
processOP
verifyChunks
建立连接，然后发送CheckSumHeader
这里应该是建立socket连接
PacketResponder
BlockReceiver
mirrorPacketTo(mirrorOut)
0 条评论
下一页
