org.apache.hadoop.hdfs.server.blockmanagement

Class DatanodeStorageInfo

java.lang.Object

org.apache.hadoop.hdfs.server.blockmanagement.DatanodeStorageInfo

public class DatanodeStorageInfo
extends Object

A Datanode has one or more storages. A storage in the Datanode is represented by this class.

Field Summary

Fields

Modifier and Type	Field and Description
static DatanodeStorageInfo[]	EMPTY_ARRAY

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.hdfs.server.blockmanagement.DatanodeStorageInfo.AddBlockResult	addBlock(org.apache.hadoop.hdfs.server.blockmanagement.BlockInfo b)
boolean	areBlockContentsStale()
static void	decrementBlocksScheduled(DatanodeStorageInfo... storages) Decrement the number of blocks scheduled for each given storage.
boolean	equals(Object obj)
int	getBlockReportCount()
org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor	getDatanodeDescriptor()
String	getStorageID()
org.apache.hadoop.fs.StorageType	getStorageType()
int	hashCode()
static void	incrementBlocksScheduled(DatanodeStorageInfo... storages) Increment the number of blocks scheduled for each given storage
boolean	removeBlock(org.apache.hadoop.hdfs.server.blockmanagement.BlockInfo b)
void	setUtilizationForTesting(long capacity, long dfsUsed, long remaining, long blockPoolUsed)
static org.apache.hadoop.hdfs.protocol.DatanodeInfo[]	toDatanodeInfos(DatanodeStorageInfo[] storages)
static String[]	toStorageIDs(DatanodeStorageInfo[] storages)
static org.apache.hadoop.fs.StorageType[]	toStorageTypes(DatanodeStorageInfo[] storages)
String	toString()
void	updateFromStorage(org.apache.hadoop.hdfs.server.protocol.DatanodeStorage storage)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

EMPTY_ARRAY

public static final DatanodeStorageInfo[] EMPTY_ARRAY

Method Detail

toDatanodeInfos

public static org.apache.hadoop.hdfs.protocol.DatanodeInfo[] toDatanodeInfos(DatanodeStorageInfo[] storages)

toStorageIDs

public static String[] toStorageIDs(DatanodeStorageInfo[] storages)

toStorageTypes

public static org.apache.hadoop.fs.StorageType[] toStorageTypes(DatanodeStorageInfo[] storages)

updateFromStorage

public void updateFromStorage(org.apache.hadoop.hdfs.server.protocol.DatanodeStorage storage)

getBlockReportCount

public int getBlockReportCount()

areBlockContentsStale

public boolean areBlockContentsStale()

setUtilizationForTesting

public void setUtilizationForTesting(long capacity,
                            long dfsUsed,
                            long remaining,
                            long blockPoolUsed)

getStorageID

public String getStorageID()

getStorageType

public org.apache.hadoop.fs.StorageType getStorageType()

addBlock

public org.apache.hadoop.hdfs.server.blockmanagement.DatanodeStorageInfo.AddBlockResult addBlock(org.apache.hadoop.hdfs.server.blockmanagement.BlockInfo b)

removeBlock

public boolean removeBlock(org.apache.hadoop.hdfs.server.blockmanagement.BlockInfo b)

getDatanodeDescriptor

public org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor getDatanodeDescriptor()

incrementBlocksScheduled

public static void incrementBlocksScheduled(DatanodeStorageInfo... storages)

Increment the number of blocks scheduled for each given storage

decrementBlocksScheduled

public static void decrementBlocksScheduled(DatanodeStorageInfo... storages)

Decrement the number of blocks scheduled for each given storage. This will be called during abandon block or delete of UC block.

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object