类 org.apache.hadoop.hdfs.protocol.DatanodeInfo
的使用

使用DatanodeInfo的程序包

程序包	说明
org.apache.hadoop.hdfs	A distributed implementation of FileSystem.
org.apache.hadoop.hdfs.protocol
org.apache.hadoop.hdfs.server.datanode
org.apache.hadoop.hdfs.server.namenode
org.apache.hadoop.hdfs.server.protocol

org.apache.hadoop.hdfs中DatanodeInfo的使用

返回DatanodeInfo的org.apache.hadoop.hdfs中的方法

限定符和类型	方法和说明
DatanodeInfo[]	DFSClient.datanodeReport(FSConstants.DatanodeReportType type)
DatanodeInfo	DFSClient.DFSInputStream.getCurrentDatanode() Returns the datanode from which the stream is currently reading.
DatanodeInfo	DFSClient.DFSDataInputStream.getCurrentDatanode() Returns the datanode from which the stream is currently reading.
DatanodeInfo[]	DistributedFileSystem.getDataNodeStats() Return statistics for each datanode.
DatanodeInfo[]	ChecksumDistributedFileSystem.getDataNodeStats() Return statistics for each datanode.

参数类型为DatanodeInfo的org.apache.hadoop.hdfs中的方法

限定符和类型	方法和说明
int	DFSUtil.StaleComparator.compare(DatanodeInfo a, DatanodeInfo b)

org.apache.hadoop.hdfs.protocol中DatanodeInfo的使用

返回DatanodeInfo的org.apache.hadoop.hdfs.protocol中的方法

限定符和类型	方法和说明
DatanodeInfo[]	ClientProtocol.getDatanodeReport(FSConstants.DatanodeReportType type) Get a report on the system's current datanodes.
DatanodeInfo[]	LocatedBlock.getLocations()

参数类型为DatanodeInfo的org.apache.hadoop.hdfs.protocol中的方法

限定符和类型	方法和说明
LocatedBlock	ClientProtocol.addBlock(String src, String clientName, DatanodeInfo[] excludedNodes) A client that wants to write an additional block to the indicated filename (which must currently be open for writing) should call addBlock().
LocatedBlock	ClientDatanodeProtocol.recoverBlock(Block block, boolean keepLength, DatanodeInfo[] targets) Start generation-stamp recovery for specified block

参数类型为DatanodeInfo的org.apache.hadoop.hdfs.protocol中的构造器

构造器和说明
DatanodeInfo(DatanodeInfo from)
LocatedBlock(Block b, DatanodeInfo[] locs)
LocatedBlock(Block b, DatanodeInfo[] locs, long startOffset)
LocatedBlock(Block b, DatanodeInfo[] locs, long startOffset, boolean corrupt)
UnregisteredDatanodeException(DatanodeID nodeID, DatanodeInfo storedNode)

org.apache.hadoop.hdfs.server.datanode中DatanodeInfo的使用

参数类型为DatanodeInfo的org.apache.hadoop.hdfs.server.datanode中的方法

限定符和类型	方法和说明
static InterDatanodeProtocol	DataNode.createInterDataNodeProtocolProxy(DatanodeInfo info, Configuration conf, int socketTimeout, boolean connectToDnViaHostname)
LocatedBlock	DataNode.recoverBlock(Block block, boolean keepLength, DatanodeInfo[] targets) Start generation-stamp recovery for specified block
Daemon	DataNode.recoverBlocks(Block[] blocks, DatanodeInfo[][] targets)

org.apache.hadoop.hdfs.server.namenode中DatanodeInfo的使用

org.apache.hadoop.hdfs.server.namenode中DatanodeInfo的子类

限定符和类型	类和说明
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.

返回DatanodeInfo的org.apache.hadoop.hdfs.server.namenode中的方法

限定符和类型	方法和说明
static DatanodeInfo	JspHelper.bestNode(LocatedBlock blk)
DatanodeInfo	FSNamesystem.chooseDatanode(String srcPath, String address, long blocksize) Choose a datanode near to the given address.
DatanodeInfo[]	FSNamesystem.datanodeReport(FSConstants.DatanodeReportType type)
DatanodeInfo	FSNamesystem.getDataNodeInfo(String name)
DatanodeInfo[]	NameNode.getDatanodeReport(FSConstants.DatanodeReportType type)

参数类型为DatanodeInfo的org.apache.hadoop.hdfs.server.namenode中的方法

限定符和类型	方法和说明
LocatedBlock	NameNode.addBlock(String src, String clientName, DatanodeInfo[] excludedNodes)
void	BlockPlacementPolicy.adjustSetsWithChosenReplica(Map<String,List<DatanodeDescriptor>> rackMap, List<DatanodeDescriptor> moreThanOne, List<DatanodeDescriptor> exactlyOne, DatanodeInfo cur) Adjust rackmap, moreThanOne, and exactlyOne after removing replica on cur.
BlocksWithLocations	NameNode.getBlocks(DatanodeInfo datanode, long size) return a list of blocks & their locations on datanode whose total size is size
protected String	BlockPlacementPolicyWithNodeGroup.getRack(DatanodeInfo cur)
protected String	BlockPlacementPolicy.getRack(DatanodeInfo datanode) Get rack string from a data node
void	FSNamesystem.markBlockAsCorrupt(Block blk, DatanodeInfo dn) Mark the block belonging to datanode as corrupt

org.apache.hadoop.hdfs.server.protocol中DatanodeInfo的使用

返回DatanodeInfo的org.apache.hadoop.hdfs.server.protocol中的方法

限定符和类型	方法和说明
DatanodeInfo[][]	BlockCommand.getTargets()

参数类型为DatanodeInfo的org.apache.hadoop.hdfs.server.protocol中的方法

限定符和类型	方法和说明
BlocksWithLocations	NamenodeProtocol.getBlocks(DatanodeInfo datanode, long size) Get a list of blocks belonged to datanode whose total size is equal to size