Uses of Class
org.apache.hadoop.hdfs.server.balancer.Dispatcher.DDatanode.StorageGroup

Packages that use Dispatcher.DDatanode.StorageGroup

Package	Description
org.apache.hadoop.hdfs.server.balancer	The Balancer is a tool for balancing the data across the storage devices of an HDFS cluster.

Uses of Dispatcher.DDatanode.StorageGroup in org.apache.hadoop.hdfs.server.balancer

Classes in org.apache.hadoop.hdfs.server.balancer with type parameters of type Dispatcher.DDatanode.StorageGroup

Modifier and Type	Class	Description
static class	Dispatcher.StorageGroupMap<G extends Dispatcher.DDatanode.StorageGroup>

Subclasses of Dispatcher.DDatanode.StorageGroup in org.apache.hadoop.hdfs.server.balancer

Modifier and Type	Class	Description
class	Dispatcher.Source	A node that can be the sources of a block move

Methods in org.apache.hadoop.hdfs.server.balancer that return Dispatcher.DDatanode.StorageGroup

Modifier and Type	Method	Description
Dispatcher.DDatanode.StorageGroup	Dispatcher.DDatanode.addTarget(org.apache.hadoop.fs.StorageType storageType, long maxSize2Move)

Methods in org.apache.hadoop.hdfs.server.balancer that return types with arguments of type Dispatcher.DDatanode.StorageGroup

Modifier and Type	Method	Description
Dispatcher.StorageGroupMap<Dispatcher.DDatanode.StorageGroup>	Dispatcher.getStorageGroupMap()

Methods in org.apache.hadoop.hdfs.server.balancer with parameters of type Dispatcher.DDatanode.StorageGroup

Modifier and Type	Method	Description
Dispatcher.PendingMove	Dispatcher.Source.addPendingMove(Dispatcher.DBlock block, Dispatcher.DDatanode.StorageGroup target)	Add a pending move
long	Dispatcher.DBlock.getNumBytes(Dispatcher.DDatanode.StorageGroup storage)
long	Dispatcher.DBlockStriped.getNumBytes(Dispatcher.DDatanode.StorageGroup storage)

Method parameters in org.apache.hadoop.hdfs.server.balancer with type arguments of type Dispatcher.DDatanode.StorageGroup

Modifier and Type	Method	Description
static void	Dispatcher.checkForBlockPinningFailures(Map<Long,Set<org.apache.hadoop.hdfs.protocol.DatanodeInfo>> excludedPinnedBlocks, Iterable<? extends Dispatcher.DDatanode.StorageGroup> targets)	Check any of the block movements are failed due to block pinning errors.
static boolean	Dispatcher.checkForSuccess(Iterable<? extends Dispatcher.DDatanode.StorageGroup> targets)
static boolean	Dispatcher.waitForMoveCompletion(Iterable<? extends Dispatcher.DDatanode.StorageGroup> targets)	Wait for all reportedBlock move confirmations.