alluxio.client.block.policy

Class MostAvailableFirstPolicy

java.lang.Object

alluxio.client.block.policy.MostAvailableFirstPolicy

All Implemented Interfaces:

BlockLocationPolicy

@ThreadSafe
public final class MostAvailableFirstPolicy
extends Object
implements BlockLocationPolicy

A policy that returns the worker with the most available bytes.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.client.block.policy.BlockLocationPolicy

BlockLocationPolicy.Factory

Constructor Summary

Constructors

Constructor and Description
MostAvailableFirstPolicy(AlluxioConfiguration ignoredConf) Constructs a new MostAvailableFirstPolicy needed for instantiation in BlockLocationPolicy.Factory.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Optional<WorkerNetAddress>	getWorker(GetWorkerOptions options) The policy returns null if no worker is qualified.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MostAvailableFirstPolicy

public MostAvailableFirstPolicy(AlluxioConfiguration ignoredConf)

Constructs a new MostAvailableFirstPolicy needed for instantiation in BlockLocationPolicy.Factory.

Parameters:

ignoredConf - is unused

Method Detail

getWorker

public Optional<WorkerNetAddress> getWorker(GetWorkerOptions options)

The policy returns null if no worker is qualified.

Specified by:

getWorker in interface BlockLocationPolicy

Parameters:

options - the options to get a block worker network address for a block

Returns:

the address of the worker to write to, or empty if no worker can be selected

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object