Uses of Class
org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor

Packages that use DatanodeDescriptor

Package	Description
org.apache.hadoop.hdfs.server.blockmanagement
org.apache.hadoop.hdfs.server.namenode

Uses of DatanodeDescriptor in org.apache.hadoop.hdfs.server.blockmanagement

Subclasses of DatanodeDescriptor in org.apache.hadoop.hdfs.server.blockmanagement

Modifier and Type	Class	Description
static class	ProvidedStorageMap.ProvidedDescriptor	An abstract DatanodeDescriptor to track datanodes with provided storages.

Fields in org.apache.hadoop.hdfs.server.blockmanagement declared as DatanodeDescriptor

Modifier and Type	Field	Description
static final DatanodeDescriptor[]	DatanodeDescriptor.EMPTY_ARRAY

Methods in org.apache.hadoop.hdfs.server.blockmanagement that return DatanodeDescriptor

Modifier and Type	Method	Description
protected DatanodeDescriptor	AvailableSpaceBlockPlacementPolicy.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNode)
protected DatanodeDescriptor	AvailableSpaceBlockPlacementPolicy.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNode, org.apache.hadoop.fs.StorageType type)
protected DatanodeDescriptor	AvailableSpaceRackFaultTolerantBlockPlacementPolicy.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNode)
protected DatanodeDescriptor	AvailableSpaceRackFaultTolerantBlockPlacementPolicy.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNode, org.apache.hadoop.fs.StorageType type)
protected DatanodeDescriptor	BlockPlacementPolicyDefault.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNodes)	Choose a datanode from the given scope.
protected DatanodeDescriptor	BlockPlacementPolicyDefault.chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNodes, org.apache.hadoop.fs.StorageType type)	Choose a datanode from the given scope with specified storage type.
DatanodeDescriptor	ProvidedStorageMap.chooseProvidedDatanode()	Choose a datanode that reported a volume of StorageType PROVIDED.
DatanodeDescriptor	BlockInfo.getDatanode(int index)
DatanodeDescriptor	DatanodeDescriptor.CachedBlocksList.getDatanode()
DatanodeDescriptor	DatanodeManager.getDatanode(String datanodeUuid)	Get a datanode descriptor given corresponding DatanodeUUID
DatanodeDescriptor	DatanodeManager.getDatanode(org.apache.hadoop.hdfs.protocol.DatanodeID nodeID)	Get data node by datanode ID.
DatanodeDescriptor	DatanodeManager.getDatanodeByHost(String host)
DatanodeDescriptor	DatanodeManager.getDatanodeByHostName(String hostname)
DatanodeDescriptor	DatanodeManager.getDatanodeByXferAddr(String host, int xferPort)
DatanodeDescriptor	DatanodeStorageInfo.getDatanodeDescriptor()

Methods in org.apache.hadoop.hdfs.server.blockmanagement that return types with arguments of type DatanodeDescriptor

Modifier and Type	Method	Description
List<DatanodeDescriptor>	DatanodeManager.getAllSlowDataNodes()
Queue<DatanodeDescriptor>	DatanodeAdminMonitorBase.getCancelledNodes()
Queue<DatanodeDescriptor>	DatanodeAdminMonitorInterface.getCancelledNodes()
Collection<DatanodeDescriptor>	BlockManager.getCorruptReplicas(org.apache.hadoop.hdfs.protocol.Block block)	Get the replicas which are corrupt for a given block.
List<DatanodeDescriptor>	DatanodeManager.getDatanodeListForReport(org.apache.hadoop.hdfs.protocol.HdfsConstants.DatanodeReportType type)	For generating datanode reports
Map<String,DatanodeDescriptor>	DatanodeManager.getDatanodeMap()
Set<DatanodeDescriptor>	DatanodeManager.getDatanodes()
List<DatanodeDescriptor>	DatanodeManager.getDecommissioningNodes()
List<DatanodeDescriptor>	DatanodeManager.getEnteringMaintenanceNodes()
Queue<DatanodeDescriptor>	DatanodeAdminManager.getPendingNodes()
Queue<DatanodeDescriptor>	DatanodeAdminMonitorBase.getPendingNodes()
Queue<DatanodeDescriptor>	DatanodeAdminMonitorInterface.getPendingNodes()

Methods in org.apache.hadoop.hdfs.server.blockmanagement with parameters of type DatanodeDescriptor

Modifier and Type	Method	Description
protected int	BlockPlacementPolicyDefault.addToExcludedNodes(DatanodeDescriptor localMachine, Set<org.apache.hadoop.net.Node> excludedNodes)	Add localMachine and related nodes to excludedNodes for next replica choosing.
protected int	BlockPlacementPolicyWithNodeGroup.addToExcludedNodes(DatanodeDescriptor chosenNode, Set<org.apache.hadoop.net.Node> excludedNodes)	Find other nodes in the same nodegroup of localMachine and add them into excludeNodes as replica should not be duplicated for nodes within the same nodegroup
protected void	BlockPlacementPolicyDefault.chooseRemoteRack(int numOfReplicas, DatanodeDescriptor localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxReplicasPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose numOfReplicas nodes from the racks that localMachine is NOT on.
protected void	BlockPlacementPolicyWithNodeGroup.chooseRemoteRack(int numOfReplicas, DatanodeDescriptor localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxReplicasPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
abstract List<DatanodeStorageInfo>	BlockPlacementPolicy.chooseReplicasToDelete(Collection<DatanodeStorageInfo> availableReplicas, Collection<DatanodeStorageInfo> delCandidates, int expectedNumOfReplicas, List<org.apache.hadoop.fs.StorageType> excessTypes, DatanodeDescriptor addedNode, DatanodeDescriptor delNodeHint)	Select the excess replica storages for deletion based on either delNodehint/Excess storage types.
List<DatanodeStorageInfo>	BlockPlacementPolicyDefault.chooseReplicasToDelete(Collection<DatanodeStorageInfo> availableReplicas, Collection<DatanodeStorageInfo> delCandidates, int expectedNumOfReplicas, List<org.apache.hadoop.fs.StorageType> excessTypes, DatanodeDescriptor addedNode, DatanodeDescriptor delNodeHint)
DatanodeStorageInfo[]	BlockManager.chooseTarget4WebHDFS(String src, DatanodeDescriptor clientnode, Set<org.apache.hadoop.net.Node> excludes, long blocksize)	Choose target for WebHDFS redirection.
protected int	AvailableSpaceBlockPlacementPolicy.compareDataNode(DatanodeDescriptor a, DatanodeDescriptor b, boolean isBalanceLocal)	Compare the two data nodes.
protected int	AvailableSpaceRackFaultTolerantBlockPlacementPolicy.compareDataNode(DatanodeDescriptor a, DatanodeDescriptor b)	Compare the two data nodes.
String	BlockManager.getCorruptReason(org.apache.hadoop.hdfs.protocol.Block block, DatanodeDescriptor node)	Get reason for certain corrupted replicas for a given block and a given dn.
boolean	BlockManager.isExcess(DatanodeDescriptor dn, BlockInfo blk)
protected boolean	BlockPlacementPolicyWithUpgradeDomain.isGoodDatanode(DatanodeDescriptor node, int maxTargetPerRack, boolean considerLoad, List<DatanodeStorageInfo> results, boolean avoidStaleNodes)
protected void	DatanodeAdminManager.logBlockReplicationInfo(BlockInfo block, BlockCollection bc, DatanodeDescriptor srcNode, NumberReplicas num, Iterable<DatanodeStorageInfo> storages)
protected static void	BlockPlacementPolicyDefault.logNodeIsNotChosen(DatanodeDescriptor node, BlockPlacementPolicyDefault.NodeNotChosenReason reason, String reasonDetails)
void	BlockManagerFaultInjector.removeBlockReportLease(DatanodeDescriptor node, long leaseId)
void	ProvidedStorageMap.removeDatanode(DatanodeDescriptor dnToRemove)
void	BlockManager.removeStoredBlock(BlockInfo storedBlock, DatanodeDescriptor node)	Modify (block-->datanode) map.
void	BlockManagerFaultInjector.requestBlockReportLease(DatanodeDescriptor node, long leaseId)
protected void	DatanodeAdminManager.setDecommissioned(DatanodeDescriptor dn)
protected void	DatanodeAdminManager.setInMaintenance(DatanodeDescriptor dn)
void	DatanodeAdminManager.startDecommission(DatanodeDescriptor node)	Start decommissioning the specified datanode.
void	DatanodeAdminManager.startMaintenance(DatanodeDescriptor node, long maintenanceExpireTimeInMS)	Start maintenance of the specified datanode.
void	DatanodeAdminMonitorBase.startTrackingNode(DatanodeDescriptor dn)	Start tracking a node for decommission or maintenance.
void	DatanodeAdminMonitorInterface.startTrackingNode(DatanodeDescriptor dn)
void	DatanodeAdminManager.stopDecommission(DatanodeDescriptor node)	Stop decommissioning the specified datanode.
void	DatanodeAdminManager.stopMaintenance(DatanodeDescriptor node)	Stop maintenance of the specified datanode.
void	DatanodeAdminBackoffMonitor.stopTrackingNode(DatanodeDescriptor dn)	Queue a node to be removed from tracking.
void	DatanodeAdminDefaultMonitor.stopTrackingNode(DatanodeDescriptor dn)
void	DatanodeAdminMonitorInterface.stopTrackingNode(DatanodeDescriptor dn)
void	ProvidedStorageMap.updateStorage(DatanodeDescriptor node, org.apache.hadoop.hdfs.server.protocol.DatanodeStorage storage)

Method parameters in org.apache.hadoop.hdfs.server.blockmanagement with type arguments of type DatanodeDescriptor

Modifier and Type	Method	Description
protected void	BlockPlacementPolicyDefault.chooseFavouredNodes(String src, int numOfReplicas, List<DatanodeDescriptor> favoredNodes, Set<org.apache.hadoop.net.Node> favoriteAndExcludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected void	BlockPlacementPolicyWithNodeGroup.chooseFavouredNodes(String src, int numOfReplicas, List<DatanodeDescriptor> favoredNodes, Set<org.apache.hadoop.net.Node> favoriteAndExcludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	choose all good favored nodes as target.
void	DatanodeManager.fetchDatanodes(List<DatanodeDescriptor> live, List<DatanodeDescriptor> dead, boolean removeDecommissionNode)	Fetch live and dead datanodes.

Uses of DatanodeDescriptor in org.apache.hadoop.hdfs.server.namenode

Methods in org.apache.hadoop.hdfs.server.namenode that return types with arguments of type DatanodeDescriptor

Modifier and Type	Method	Description
List<DatanodeDescriptor>	CachedBlock.getDatanodes(DatanodeDescriptor.CachedBlocksList.Type type)	Get a list of the datanodes which this block is cached, planned to be cached, or planned to be uncached on.