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

Class AvailableSpaceVolumeChoosingPolicy<V extends FsVolumeSpi>

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.fsdataset.AvailableSpaceVolumeChoosingPolicy<V>

All Implemented Interfaces:

Configurable, VolumeChoosingPolicy<V>

public class AvailableSpaceVolumeChoosingPolicy<V extends FsVolumeSpi>
extends Object
implements VolumeChoosingPolicy<V>, Configurable

A DN volume choosing policy which takes into account the amount of free space on each of the available volumes when considering where to assign a new replica allocation. By default this policy prefers assigning replicas to those volumes with more available free space, so as to over time balance the available space of all the volumes within a DN.

Constructor Summary

Constructors

Constructor and Description
AvailableSpaceVolumeChoosingPolicy()

Method Summary

Methods

Modifier and Type	Method and Description
V	chooseVolume(List<V> volumes, long replicaSize) Choose a volume to place a replica, given a list of volumes and the replica size sought for storage.
Configuration	getConf() Return the configuration used by this object.
void	setConf(Configuration conf) Set the configuration to be used by this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvailableSpaceVolumeChoosingPolicy

public AvailableSpaceVolumeChoosingPolicy()

Method Detail

setConf

public void setConf(Configuration conf)

Description copied from interface: Configurable

Set the configuration to be used by this object.

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Description copied from interface: Configurable

Return the configuration used by this object.

Specified by:

getConf in interface Configurable

chooseVolume

public V chooseVolume(List<V> volumes,
             long replicaSize)
                                   throws IOException

Description copied from interface: VolumeChoosingPolicy

Choose a volume to place a replica, given a list of volumes and the replica size sought for storage. The implementations of this interface must be thread-safe.

Specified by:

chooseVolume in interface VolumeChoosingPolicy<V extends FsVolumeSpi>

Parameters:

volumes - - a list of available volumes.

replicaSize - - the size of the replica for which a volume is sought.

Returns:

the chosen volume.

Throws:

IOException - when disks are unavailable or are full.