Package org.apache.hadoop.hdfs.server.datanode.fsdataset.impl

Class BlockPoolSlice

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.fsdataset.impl.BlockPoolSlice

public class BlockPoolSlice
extends Object

A block pool slice represents a portion of a block pool stored on a volume. Taken together, all BlockPoolSlices sharing a block pool ID across a cluster represent a single block pool. This class is synchronized by FsVolumeImpl.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DU_CACHE_FILE

Method Summary

Modifier and Type	Method	Description
static int	getAddReplicaForkPoolSize()	Return the size of fork pool used for adding replica in map.
ForkJoinPool	getAddReplicaThreadPool()
org.apache.hadoop.fs.GetSpaceUsed	getDfsUsage()
long	getNumOfBlocks()
static void	reInitializeAddReplicaThreadPool()
String	toString()
void	updateDfsUsageConfig(Long interval, Long jitter, Class<? extends org.apache.hadoop.fs.GetSpaceUsed> klass)

Methods inherited from class java.lang.Object

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

Field Details

DU_CACHE_FILE

@VisibleForTesting
public static final String DU_CACHE_FILE

See Also:

• Constant Field Values

Method Details

updateDfsUsageConfig

public void updateDfsUsageConfig(Long interval,
 Long jitter,
 Class<? extends org.apache.hadoop.fs.GetSpaceUsed> klass)
                          throws IOException

Throws:

IOException

getDfsUsage

@VisibleForTesting
public org.apache.hadoop.fs.GetSpaceUsed getDfsUsage()

toString

public String toString()

Overrides:

toString in class Object

getNumOfBlocks

public long getNumOfBlocks()

getAddReplicaForkPoolSize

@VisibleForTesting
public static int getAddReplicaForkPoolSize()

Return the size of fork pool used for adding replica in map.

getAddReplicaThreadPool

@VisibleForTesting
public ForkJoinPool getAddReplicaThreadPool()

reInitializeAddReplicaThreadPool

@VisibleForTesting
public static void reInitializeAddReplicaThreadPool()