org.apache.hadoop.hdfs.server.blockmanagement

Class AvailableSpaceBlockPlacementPolicy

java.lang.Object

org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy

org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

org.apache.hadoop.hdfs.server.blockmanagement.AvailableSpaceBlockPlacementPolicy

public class AvailableSpaceBlockPlacementPolicy
extends org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

Space balanced block placement policy.

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

clusterMap, considerLoad, considerLoadFactor, heartbeatInterval, host2datanodeMap, tolerateHeartbeatMultiplier

Constructor Summary

Constructors

Constructor and Description
AvailableSpaceBlockPlacementPolicy()

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor	chooseDataNode(String scope, Collection<org.apache.hadoop.net.Node> excludedNode) Choose a datanode from the given scope.
protected int	compareDataNode(org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor a, org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor b) Compare the two data nodes.
void	initialize(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hdfs.server.blockmanagement.FSClusterStats stats, org.apache.hadoop.net.NetworkTopology clusterMap, org.apache.hadoop.hdfs.server.blockmanagement.Host2NodesMap host2datanodeMap) Used to setup a BlockPlacementPolicy object.

Methods inherited from class org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

addToExcludedNodes, chooseFavouredNodes, chooseLocalRack, chooseLocalStorage, chooseLocalStorage, chooseRandom, chooseRandom, chooseRemoteRack, chooseReplicasToDelete, chooseReplicaToDelete, chooseTarget, chooseTargetInOrder, getMaxNodesPerRack, isMovable, pickupReplicaSet, verifyBlockPlacement

Methods inherited from class org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy

adjustSetsWithChosenReplica, getDatanodeInfo, getInstance, getRack, splitNodesWithRack

Methods inherited from class java.lang.Object

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

Constructor Detail

AvailableSpaceBlockPlacementPolicy

public AvailableSpaceBlockPlacementPolicy()

Method Detail

initialize

public void initialize(org.apache.hadoop.conf.Configuration conf,
              org.apache.hadoop.hdfs.server.blockmanagement.FSClusterStats stats,
              org.apache.hadoop.net.NetworkTopology clusterMap,
              org.apache.hadoop.hdfs.server.blockmanagement.Host2NodesMap host2datanodeMap)

Description copied from class: org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy

Used to setup a BlockPlacementPolicy object. This should be defined by all implementations of a BlockPlacementPolicy.

Overrides:

initialize in class org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

Parameters:

conf - the configuration object

stats - retrieve cluster status from here

clusterMap - cluster topology

chooseDataNode

protected org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor chooseDataNode(String scope,
                                                                              Collection<org.apache.hadoop.net.Node> excludedNode)

Description copied from class: org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

Choose a datanode from the given scope.

Overrides:

chooseDataNode in class org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicyDefault

Returns:

the chosen node, if there is any.

compareDataNode

protected int compareDataNode(org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor a,
                  org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor b)

Compare the two data nodes.