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

Packages that use DatanodeStorageInfo

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

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

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

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

Fields in org.apache.hadoop.hdfs.server.blockmanagement with type parameters of type DatanodeStorageInfo

Modifier and Type	Field	Description
protected final Map<String,DatanodeStorageInfo>	DatanodeDescriptor.storageMap

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

Modifier and Type	Method	Description
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalOrFavoredStorage(org.apache.hadoop.net.Node localOrFavoredNode, boolean isFavoredNode, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose storage of local or favored node.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalRack(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose one node from the rack that localMachine is on.
protected DatanodeStorageInfo	BlockPlacementPolicyWithNodeGroup.chooseLocalRack(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected DatanodeStorageInfo	AvailableSpaceBlockPlacementPolicy.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToLocalRack)
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToLocalRack)	Choose localMachine as the target.
protected DatanodeStorageInfo	BlockPlacementPolicyWithNodeGroup.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToNodeGroupAndLocalRack)	choose local node of localMachine as the target.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseRandom(int numOfReplicas, String scope, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Randomly choose numOfReplicas targets from the given scope.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseRandom(String scope, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Randomly choose one target from the given scope.
DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseReplicaToDelete(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, List<org.apache.hadoop.fs.StorageType> excessTypes, Map<String,List<DatanodeStorageInfo>> rackMap)	Decide whether deleting the specified replica of the block still makes the block conform to the configured block placement policy.
DatanodeStorageInfo	DatanodeDescriptor.chooseStorage4Block(org.apache.hadoop.fs.StorageType t, long blockSize, int minBlocksForWrite)	Find whether the datanode contains good storage of given type to place block of size blockSize.
abstract DatanodeStorageInfo[]	BlockPlacementPolicy.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags)	choose numOfReplicas data nodes for writer to re-replicate a block with size blocksize If not, return as many as we can.
DatanodeStorageInfo[]	BlockPlacementPolicy.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
DatanodeStorageInfo[]	BlockPlacementPolicyDefault.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosenNodes, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags)
DatanodeStorageInfo[]	BlockPlacementPolicyDefault.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
DatanodeStorageInfo[]	BlockManager.chooseTarget4AdditionalDatanode(String src, int numAdditionalNodes, org.apache.hadoop.net.Node clientnode, List<DatanodeStorageInfo> chosen, Set<org.apache.hadoop.net.Node> excludes, long blocksize, byte storagePolicyID, org.apache.hadoop.hdfs.protocol.BlockType blockType)	Choose target for getting additional datanodes for an existing pipeline.
DatanodeStorageInfo[]	BlockManager.chooseTarget4NewBlock(String src, int numOfReplicas, org.apache.hadoop.net.Node client, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, List<String> favoredNodes, byte storagePolicyID, org.apache.hadoop.hdfs.protocol.BlockType blockType, org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy ecPolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags)	Choose target datanodes for creating a new block.
DatanodeStorageInfo[]	BlockManager.chooseTarget4WebHDFS(String src, DatanodeDescriptor clientnode, Set<org.apache.hadoop.net.Node> excludes, long blocksize)	Choose target for WebHDFS redirection.
DatanodeStorageInfo[]	DatanodeManager.getDatanodeStorageInfos(org.apache.hadoop.hdfs.protocol.DatanodeID[] datanodeID, String[] storageIDs, String format, Object... args)
DatanodeStorageInfo[]	BlockUnderConstructionFeature.getExpectedStorageLocations()	Create array of expected replica locations (as has been assigned by chooseTargets()).
DatanodeStorageInfo	ProvidedStorageMap.getProvidedStorageInfo()
DatanodeStorageInfo	BlockInfoStriped.StorageAndBlockIndex.getStorage()
DatanodeStorageInfo	DatanodeDescriptor.getStorageInfo(String storageID)
DatanodeStorageInfo[]	DatanodeDescriptor.getStorageInfos()
DatanodeStorageInfo[]	BlockManager.getStorages(BlockInfo block)

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

Modifier and Type	Method	Description
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)
Iterator<DatanodeStorageInfo>	BlockUnderConstructionFeature.getExpectedStorageLocationsIterator()	Note that this iterator doesn't guarantee thread-safe.
Iterator<DatanodeStorageInfo>	BlockInfo.getStorageInfos()
Iterable<DatanodeStorageInfo>	BlockManager.getStorages(org.apache.hadoop.hdfs.protocol.Block block)
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyDefault.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyRackFaultTolerant.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)
Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithNodeGroup.pickupReplicaSet(Collection<DatanodeStorageInfo> first, Collection<DatanodeStorageInfo> second, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithUpgradeDomain.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)

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

Modifier and Type	Method	Description
void	BlockManager.addBlock(DatanodeStorageInfo storageInfo, org.apache.hadoop.hdfs.protocol.Block block, String delHint)	The given node is reporting that it received a certain block.
void	DatanodeDescriptor.addBlockToBeReplicated(org.apache.hadoop.hdfs.protocol.Block block, DatanodeStorageInfo[] targets)	Store block replication work.
void	ProvidedStorageMap.ProvidedDescriptor.addBlockToBeReplicated(org.apache.hadoop.hdfs.protocol.Block block, DatanodeStorageInfo[] targets)
void	DatanodeDescriptor.addECBlockToBeReplicated(org.apache.hadoop.hdfs.protocol.Block block, DatanodeStorageInfo[] targets)	Store ec block to be replicated work.
void	BlockPlacementPolicy.adjustSetsWithChosenReplica(Map<String,List<DatanodeStorageInfo>> rackMap, List<DatanodeStorageInfo> moreThanOne, List<DatanodeStorageInfo> exactlyOne, DatanodeStorageInfo cur)	Adjust rackmap, moreThanOne, and exactlyOne after removing replica on cur.
void	BlockCollection.convertLastBlockToUC(BlockInfo lastBlock, DatanodeStorageInfo[] targets)	Convert the last block of the collection to an under-construction block and set the locations.
void	BlockInfo.convertToBlockUnderConstruction(HdfsServerConstants.BlockUCState s, DatanodeStorageInfo[] targets)	Add/Update the under construction feature.
static void	DatanodeStorageInfo.decrementBlocksScheduled(DatanodeStorageInfo... storages)	Decrement the number of blocks scheduled for each given storage.
byte	BlockInfoStriped.getStorageBlockIndex(DatanodeStorageInfo storage)
static void	DatanodeStorageInfo.incrementBlocksScheduled(DatanodeStorageInfo... storages)	Increment the number of blocks scheduled for each given storage
void	BlockManager.markBlockReplicasAsCorrupt(org.apache.hadoop.hdfs.protocol.Block oldBlock, BlockInfo block, long oldGenerationStamp, long oldNumBytes, DatanodeStorageInfo[] newStorages)	Mark block replicas as corrupt except those on the storages in newStorages list.
BlockInfo	BlockInfo.moveBlockToHead(BlockInfo head, DatanodeStorageInfo storage, int curIndex, int headIndex)	Remove this block from the list of blocks related to the specified DatanodeDescriptor.
static org.apache.hadoop.hdfs.protocol.LocatedBlock	BlockManager.newLocatedBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock eb, BlockInfo info, DatanodeStorageInfo[] locs, long offset)
static org.apache.hadoop.hdfs.protocol.LocatedBlock	BlockManager.newLocatedBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock b, DatanodeStorageInfo[] storages, long startOffset, boolean corrupt)
static org.apache.hadoop.hdfs.protocol.LocatedStripedBlock	BlockManager.newLocatedStripedBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock b, DatanodeStorageInfo[] storages, byte[] indices, long startOffset, boolean corrupt)
void	BlockUnderConstructionFeature.setExpectedLocations(org.apache.hadoop.hdfs.protocol.Block block, DatanodeStorageInfo[] targets, org.apache.hadoop.hdfs.protocol.BlockType blockType)	Set expected locations
static org.apache.hadoop.hdfs.protocol.DatanodeInfo[]	DatanodeStorageInfo.toDatanodeInfos(DatanodeStorageInfo[] storages)
static String[]	DatanodeStorageInfo.toStorageIDs(DatanodeStorageInfo[] storages)
static org.apache.hadoop.fs.StorageType[]	DatanodeStorageInfo.toStorageTypes(DatanodeStorageInfo[] storages)

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

Modifier and Type	Method	Description
void	BlockPlacementPolicy.adjustSetsWithChosenReplica(Map<String,List<DatanodeStorageInfo>> rackMap, List<DatanodeStorageInfo> moreThanOne, List<DatanodeStorageInfo> exactlyOne, DatanodeStorageInfo cur)	Adjust rackmap, moreThanOne, and exactlyOne after removing replica on cur.
void	BlockPlacementPolicy.adjustSetsWithChosenReplica(Map<String,List<DatanodeStorageInfo>> rackMap, List<DatanodeStorageInfo> moreThanOne, List<DatanodeStorageInfo> exactlyOne, DatanodeStorageInfo cur)	Adjust rackmap, moreThanOne, and exactlyOne after removing replica on cur.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalOrFavoredStorage(org.apache.hadoop.net.Node localOrFavoredNode, boolean isFavoredNode, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose storage of local or favored node.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalRack(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose one node from the rack that localMachine is on.
protected DatanodeStorageInfo	BlockPlacementPolicyWithNodeGroup.chooseLocalRack(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected DatanodeStorageInfo	AvailableSpaceBlockPlacementPolicy.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToLocalRack)
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToLocalRack)	Choose localMachine as the target.
protected DatanodeStorageInfo	BlockPlacementPolicyWithNodeGroup.chooseLocalStorage(org.apache.hadoop.net.Node localMachine, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes, boolean fallbackToNodeGroupAndLocalRack)	choose local node of localMachine as the target.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseRandom(int numOfReplicas, String scope, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Randomly choose numOfReplicas targets from the given scope.
protected DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseRandom(String scope, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Randomly choose one target from the given scope.
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	BlockPlacementPolicyDefault.chooseReplicaToDelete(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, List<org.apache.hadoop.fs.StorageType> excessTypes, Map<String,List<DatanodeStorageInfo>> rackMap)	Decide whether deleting the specified replica of the block still makes the block conform to the configured block placement policy.
DatanodeStorageInfo	BlockPlacementPolicyDefault.chooseReplicaToDelete(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, List<org.apache.hadoop.fs.StorageType> excessTypes, Map<String,List<DatanodeStorageInfo>> rackMap)	Decide whether deleting the specified replica of the block still makes the block conform to the configured block placement policy.
abstract DatanodeStorageInfo[]	BlockPlacementPolicy.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags)	choose numOfReplicas data nodes for writer to re-replicate a block with size blocksize If not, return as many as we can.
DatanodeStorageInfo[]	BlockPlacementPolicy.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
DatanodeStorageInfo[]	BlockPlacementPolicyDefault.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosenNodes, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags)
DatanodeStorageInfo[]	BlockPlacementPolicyDefault.chooseTarget(String srcPath, int numOfReplicas, org.apache.hadoop.net.Node writer, List<DatanodeStorageInfo> chosen, boolean returnChosenNodes, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, org.apache.hadoop.hdfs.protocol.BlockStoragePolicy storagePolicy, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> flags, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
DatanodeStorageInfo[]	BlockManager.chooseTarget4AdditionalDatanode(String src, int numAdditionalNodes, org.apache.hadoop.net.Node clientnode, List<DatanodeStorageInfo> chosen, Set<org.apache.hadoop.net.Node> excludes, long blocksize, byte storagePolicyID, org.apache.hadoop.hdfs.protocol.BlockType blockType)	Choose target for getting additional datanodes for an existing pipeline.
protected org.apache.hadoop.net.Node	BlockPlacementPolicyDefault.chooseTargetInOrder(int numOfReplicas, org.apache.hadoop.net.Node writer, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, boolean newBlock, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)
protected org.apache.hadoop.net.Node	BlockPlacementPolicyRackFaultTolerant.chooseTargetInOrder(int numOfReplicas, org.apache.hadoop.net.Node writer, Set<org.apache.hadoop.net.Node> excludedNodes, long blocksize, int maxNodesPerRack, List<DatanodeStorageInfo> results, boolean avoidStaleNodes, boolean newBlock, EnumMap<org.apache.hadoop.fs.StorageType,Integer> storageTypes)	Choose numOfReplicas in order: 1.
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 Collection<DatanodeStorageInfo>	BlockPlacementPolicyDefault.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyDefault.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyRackFaultTolerant.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyRackFaultTolerant.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)
Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithNodeGroup.pickupReplicaSet(Collection<DatanodeStorageInfo> first, Collection<DatanodeStorageInfo> second, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithNodeGroup.pickupReplicaSet(Collection<DatanodeStorageInfo> first, Collection<DatanodeStorageInfo> second, Map<String,List<DatanodeStorageInfo>> rackMap)	Pick up replica node set for deleting replica as over-replicated.
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithUpgradeDomain.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)
protected Collection<DatanodeStorageInfo>	BlockPlacementPolicyWithUpgradeDomain.pickupReplicaSet(Collection<DatanodeStorageInfo> moreThanOne, Collection<DatanodeStorageInfo> exactlyOne, Map<String,List<DatanodeStorageInfo>> rackMap)

Constructors in org.apache.hadoop.hdfs.server.blockmanagement with parameters of type DatanodeStorageInfo

Modifier	Constructor	Description
	BlockUnderConstructionFeature(org.apache.hadoop.hdfs.protocol.Block blk, HdfsServerConstants.BlockUCState state, DatanodeStorageInfo[] targets, org.apache.hadoop.hdfs.protocol.BlockType blockType)

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

Methods in org.apache.hadoop.hdfs.server.namenode with parameters of type DatanodeStorageInfo

Modifier and Type	Method	Description
void	INodeFile.convertLastBlockToUC(BlockInfo lastBlock, DatanodeStorageInfo[] locations)

Uses of DatanodeStorageInfo in org.apache.hadoop.hdfs.server.protocol

Constructors in org.apache.hadoop.hdfs.server.protocol with parameters of type DatanodeStorageInfo

Modifier	Constructor	Description
	BlockECReconstructionInfo(org.apache.hadoop.hdfs.protocol.ExtendedBlock block, org.apache.hadoop.hdfs.protocol.DatanodeInfo[] sources, DatanodeStorageInfo[] targetDnStorageInfo, byte[] liveBlockIndices, byte[] excludeReconstructedIndices, org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy ecPolicy)