Package | Description |
---|---|
org.apache.hadoop.hdfs.protocolPB | |
org.apache.hadoop.hdfs.server.blockmanagement | |
org.apache.hadoop.hdfs.server.protocol |
Modifier and Type | Method and Description |
---|---|
DatanodeCommand |
DatanodeProtocolClientSideTranslatorPB.blockReport(DatanodeRegistration registration,
String poolId,
StorageBlockReport[] reports) |
static DatanodeCommand |
PBHelper.convert(DatanodeProtocolProtos.DatanodeCommandProto proto) |
Modifier and Type | Method and Description |
---|---|
static DatanodeProtocolProtos.DatanodeCommandProto |
PBHelper.convert(DatanodeCommand datanodeCommand) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BalancerBandwidthCommand
Balancer bandwidth command instructs each datanode to change its value for
the max amount of network bandwidth it may use during the block balancing
operation.
|
class |
BlockCommand
A BlockCommand is an instruction to a datanode
regarding some blocks under its control.
|
class |
BlockRecoveryCommand
BlockRecoveryCommand is an instruction to a data-node to recover
the specified blocks.
|
class |
FinalizeCommand
A BlockCommand is an instruction to a datanode to register with the namenode.
|
class |
KeyUpdateCommand |
class |
RegisterCommand
A BlockCommand is an instruction to a datanode to register with the namenode.
|
Modifier and Type | Field and Description |
---|---|
static DatanodeCommand |
RegisterCommand.REGISTER |
Modifier and Type | Method and Description |
---|---|
DatanodeCommand |
DatanodeProtocol.blockReport(DatanodeRegistration registration,
String poolId,
StorageBlockReport[] reports)
blockReport() tells the NameNode about all the locally-stored blocks.
|
DatanodeCommand[] |
HeartbeatResponse.getCommands() |
Constructor and Description |
---|
HeartbeatResponse(DatanodeCommand[] cmds,
NNHAStatusHeartbeat haStatus) |
Copyright © 2013 Apache Software Foundation. All rights reserved.