Modifier and Type | Method and Description |
---|---|
static DatanodeRegistration |
PBHelper.convert(DatanodeProtocolProtos.DatanodeRegistrationProto proto) |
DatanodeRegistration |
DatanodeProtocolClientSideTranslatorPB.registerDatanode(DatanodeRegistration registration) |
Modifier and Type | Method and Description |
---|---|
void |
DatanodeProtocolClientSideTranslatorPB.blockReceivedAndDeleted(DatanodeRegistration registration,
String poolId,
StorageReceivedDeletedBlocks[] receivedAndDeletedBlocks) |
DatanodeCommand |
DatanodeProtocolClientSideTranslatorPB.blockReport(DatanodeRegistration registration,
String poolId,
StorageBlockReport[] reports) |
static DatanodeProtocolProtos.DatanodeRegistrationProto |
PBHelper.convert(DatanodeRegistration registration) |
void |
DatanodeProtocolClientSideTranslatorPB.errorReport(DatanodeRegistration registration,
int errorCode,
String msg) |
DatanodeRegistration |
DatanodeProtocolClientSideTranslatorPB.registerDatanode(DatanodeRegistration registration) |
HeartbeatResponse |
DatanodeProtocolClientSideTranslatorPB.sendHeartbeat(DatanodeRegistration registration,
StorageReport[] reports,
int xmitsInProgress,
int xceiverCount,
int failedVolumes) |
Modifier and Type | Method and Description |
---|---|
DatanodeCommand[] |
DatanodeManager.handleHeartbeat(DatanodeRegistration nodeReg,
String blockPoolId,
long capacity,
long dfsUsed,
long remaining,
long blockPoolUsed,
int xceiverCount,
int maxTransfers,
int failedVolumes)
Handle heartbeat from datanodes.
|
void |
DatanodeManager.registerDatanode(DatanodeRegistration nodeReg)
Register the given datanode with the namenode.
|
Modifier and Type | Method and Description |
---|---|
DatanodeRegistration |
DataNode.getDNRegistrationForBP(String bpid)
get BP registration by blockPool id
|
Modifier and Type | Method and Description |
---|---|
DatanodeRegistration |
DatanodeProtocol.registerDatanode(DatanodeRegistration registration)
Register Datanode.
|
Modifier and Type | Method and Description |
---|---|
void |
DatanodeProtocol.blockReceivedAndDeleted(DatanodeRegistration registration,
String poolId,
StorageReceivedDeletedBlocks[] rcvdAndDeletedBlocks)
blockReceivedAndDeleted() allows the DataNode to tell the NameNode about
recently-received and -deleted block data.
|
DatanodeCommand |
DatanodeProtocol.blockReport(DatanodeRegistration registration,
String poolId,
StorageBlockReport[] reports)
blockReport() tells the NameNode about all the locally-stored blocks.
|
void |
DatanodeProtocol.errorReport(DatanodeRegistration registration,
int errorCode,
String msg)
errorReport() tells the NameNode about something that has gone
awry.
|
DatanodeRegistration |
DatanodeProtocol.registerDatanode(DatanodeRegistration registration)
Register Datanode.
|
HeartbeatResponse |
DatanodeProtocol.sendHeartbeat(DatanodeRegistration registration,
StorageReport[] reports,
int xmitsInProgress,
int xceiverCount,
int failedVolumes)
sendHeartbeat() tells the NameNode that the DataNode is still
alive and well.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.