程序包 | 说明 |
---|---|
org.apache.hadoop.hdfs.server.datanode | |
org.apache.hadoop.hdfs.server.namenode | |
org.apache.hadoop.hdfs.server.protocol |
限定符和类型 | 字段和说明 |
---|---|
DatanodeRegistration |
DataNode.dnRegistration |
限定符和类型 | 方法和说明 |
---|---|
static void |
DataNode.setNewStorageID(DatanodeRegistration dnReg) |
限定符和类型 | 方法和说明 |
---|---|
DatanodeRegistration |
NameNode.register(DatanodeRegistration nodeReg) |
限定符和类型 | 方法和说明 |
---|---|
void |
NameNode.blockReceived(DatanodeRegistration nodeReg,
Block[] blocks,
String[] delHints) |
DatanodeCommand |
NameNode.blockReport(DatanodeRegistration nodeReg,
long[] blocks) |
void |
NameNode.blocksBeingWrittenReport(DatanodeRegistration nodeReg,
long[] blocks)
add new replica blocks to the Inode to target mapping
also add the Inode file to DataNodeDesc
|
void |
NameNode.errorReport(DatanodeRegistration nodeReg,
int errorCode,
String msg) |
DatanodeRegistration |
NameNode.register(DatanodeRegistration nodeReg) |
void |
FSNamesystem.registerDatanode(DatanodeRegistration nodeReg)
Register Datanode.
|
DatanodeCommand[] |
NameNode.sendHeartbeat(DatanodeRegistration nodeReg,
long capacity,
long dfsUsed,
long remaining,
int xmitsInProgress,
int xceiverCount)
Data node notify the name node that it is alive
Return an array of block-oriented commands for the datanode to execute.
|
void |
NameNode.verifyRequest(DatanodeRegistration nodeReg)
Verify request.
|
限定符和类型 | 方法和说明 |
---|---|
DatanodeRegistration |
DatanodeProtocol.register(DatanodeRegistration registration)
Register Datanode.
|
限定符和类型 | 方法和说明 |
---|---|
void |
DatanodeProtocol.blockReceived(DatanodeRegistration registration,
Block[] blocks,
String[] delHints)
blockReceived() allows the DataNode to tell the NameNode about
recently-received block data, with a hint for pereferred replica
to be deleted when there is any excessive blocks.
|
DatanodeCommand |
DatanodeProtocol.blockReport(DatanodeRegistration registration,
long[] blocks)
blockReport() tells the NameNode about all the locally-stored blocks.
|
void |
DatanodeProtocol.blocksBeingWrittenReport(DatanodeRegistration registration,
long[] blocks)
blocksBeingWrittenReport() tells the NameNode about the blocks-being-
written information
|
void |
DatanodeProtocol.errorReport(DatanodeRegistration registration,
int errorCode,
String msg)
errorReport() tells the NameNode about something that has gone
awry.
|
DatanodeRegistration |
DatanodeProtocol.register(DatanodeRegistration registration)
Register Datanode.
|
DatanodeCommand[] |
DatanodeProtocol.sendHeartbeat(DatanodeRegistration registration,
long capacity,
long dfsUsed,
long remaining,
int xmitsInProgress,
int xceiverCount)
sendHeartbeat() tells the NameNode that the DataNode is still
alive and well.
|
Copyright © 2009 The Apache Software Foundation