程序包 | 说明 |
---|---|
org.apache.hadoop.hdfs.protocol | |
org.apache.hadoop.hdfs.server.namenode | |
org.apache.hadoop.hdfs.server.protocol |
限定符和类型 | 类和说明 |
---|---|
class |
DatanodeInfo
DatanodeInfo represents the status of a DataNode.
|
限定符和类型 | 字段和说明 |
---|---|
static DatanodeID[] |
DatanodeID.EMPTY_ARRAY |
限定符和类型 | 方法和说明 |
---|---|
int |
DatanodeID.compareTo(DatanodeID that)
Comparable.
|
void |
DatanodeID.updateRegInfo(DatanodeID nodeReg)
Update fields when a new registration request comes in.
|
构造器和说明 |
---|
DatanodeID(DatanodeID from)
DatanodeID copy constructor
|
DatanodeInfo(DatanodeID nodeID) |
DatanodeInfo(DatanodeID nodeID,
String location,
String hostName) |
UnregisteredDatanodeException(DatanodeID nodeID) |
UnregisteredDatanodeException(DatanodeID nodeID,
DatanodeInfo storedNode) |
限定符和类型 | 类和说明 |
---|---|
class |
DatanodeDescriptor
DatanodeDescriptor tracks stats on a given DataNode,
such as available storage capacity, last update time, etc.,
and maintains a set of blocks stored on the datanode.
|
限定符和类型 | 方法和说明 |
---|---|
DatanodeID |
JspHelper.randomNode() |
限定符和类型 | 方法和说明 |
---|---|
void |
FSNamesystem.blockReceived(DatanodeID nodeID,
Block block,
String delHint)
The given node is reporting that it received a certain block.
|
void |
NameNode.commitBlockSynchronization(Block block,
long newgenerationstamp,
long newlength,
boolean closeFile,
boolean deleteblock,
DatanodeID[] newtargets)
Commit block synchronization in lease recovery
|
void |
FSNamesystem.commitBlockSynchronization(Block lastblock,
long newgenerationstamp,
long newlength,
boolean closeFile,
boolean deleteblock,
DatanodeID[] newtargets) |
DatanodeDescriptor |
FSNamesystem.getDatanode(DatanodeID nodeID)
Get data node by storage ID.
|
void |
FSNamesystem.processBlocksBeingWrittenReport(DatanodeID nodeID,
BlockListAsLongs blocksBeingWritten)
It will update the targets for INodeFileUnderConstruction
|
void |
FSNamesystem.processReport(DatanodeID nodeID,
BlockListAsLongs newReport)
The given node is reporting all its blocks.
|
void |
FSNamesystem.removeDatanode(DatanodeID nodeID)
remove a datanode descriptor
|
构造器和说明 |
---|
DatanodeDescriptor(DatanodeID nodeID)
DatanodeDescriptor constructor
|
DatanodeDescriptor(DatanodeID nodeID,
long capacity,
long dfsUsed,
long remaining,
int xceiverCount)
DatanodeDescriptor constructor
|
DatanodeDescriptor(DatanodeID nodeID,
String networkLocation)
DatanodeDescriptor constructor
|
DatanodeDescriptor(DatanodeID nodeID,
String networkLocation,
String hostName)
DatanodeDescriptor constructor
|
DatanodeDescriptor(DatanodeID nodeID,
String networkLocation,
String hostName,
long capacity,
long dfsUsed,
long remaining,
int xceiverCount)
DatanodeDescriptor constructor
|
限定符和类型 | 类和说明 |
---|---|
class |
DatanodeRegistration
DatanodeRegistration class conatins all information the Namenode needs
to identify and verify a Datanode when it contacts the Namenode.
|
限定符和类型 | 方法和说明 |
---|---|
void |
DatanodeProtocol.commitBlockSynchronization(Block block,
long newgenerationstamp,
long newlength,
boolean closeFile,
boolean deleteblock,
DatanodeID[] newtargets)
Commit block synchronization in lease recovery
|
构造器和说明 |
---|
DisallowedDatanodeException(DatanodeID nodeID) |
Copyright © 2009 The Apache Software Foundation