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

Class ProvidedStorageMap

java.lang.Object

org.apache.hadoop.hdfs.server.blockmanagement.ProvidedStorageMap

@Private
@Unstable
public class ProvidedStorageMap
extends Object

This class allows us to manage and multiplex between storages local to datanodes, and provided storage.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method	Description
DatanodeDescriptor	chooseProvidedDatanode()	Choose a datanode that reported a volume of StorageType PROVIDED.
BlockAliasMap	getAliasMap()
long	getCapacity()
DatanodeStorageInfo	getProvidedStorageInfo()
org.apache.hadoop.hdfs.server.blockmanagement.LocatedBlockBuilder	newLocatedBlocks(int maxValue)
void	removeDatanode(DatanodeDescriptor dnToRemove)
void	updateStorage(DatanodeDescriptor node, org.apache.hadoop.hdfs.server.protocol.DatanodeStorage storage)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getProvidedStorageInfo

@VisibleForTesting
public DatanodeStorageInfo getProvidedStorageInfo()

newLocatedBlocks

public org.apache.hadoop.hdfs.server.blockmanagement.LocatedBlockBuilder newLocatedBlocks(int maxValue)

removeDatanode

public void removeDatanode(DatanodeDescriptor dnToRemove)

getCapacity

public long getCapacity()

updateStorage

public void updateStorage(DatanodeDescriptor node,
 org.apache.hadoop.hdfs.server.protocol.DatanodeStorage storage)

chooseProvidedDatanode

public DatanodeDescriptor chooseProvidedDatanode()

Choose a datanode that reported a volume of StorageType PROVIDED.

Returns:

the DatanodeDescriptor corresponding to a datanode that reported a volume with StorageType PROVIDED. If multiple datanodes report a PROVIDED volume, one is chosen uniformly at random.

getAliasMap

@VisibleForTesting
public BlockAliasMap getAliasMap()