alluxio.client.block.policy

Class LocalFirstAvoidEvictionPolicy

java.lang.Object

alluxio.client.block.policy.LocalFirstAvoidEvictionPolicy

All Implemented Interfaces:

BlockLocationPolicy

@ThreadSafe
public final class LocalFirstAvoidEvictionPolicy
extends java.lang.Object
implements BlockLocationPolicy

A policy that returns the local worker first, and if the local worker doesn't exist or doesn't have enough availability, will select the nearest worker from the active workers list with sufficient availability. The definition of 'nearest worker' is based on TieredIdentity.

See Also:

The calculation of which worker gets selected is done for each block write. The {@link alluxio.conf.PropertyKey.USER_BLOCK_AVOID_EVICTION_POLICY_RESERVED_BYTES} (alluxio.user.block.avoid.eviction.policy.reserved.size.bytes) is used as buffer space on each worker when calculating available space to store each block.

Nested Class Summary

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

BlockLocationPolicy.Factory

Constructor Summary

Constructors

Constructor and Description
LocalFirstAvoidEvictionPolicy(AlluxioConfiguration conf) Constructs a new LocalFirstAvoidEvictionPolicy.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.util.Optional<WorkerNetAddress>	getWorker(GetWorkerOptions options) Gets the worker's network address for serving operations requested for the block.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalFirstAvoidEvictionPolicy

public LocalFirstAvoidEvictionPolicy(AlluxioConfiguration conf)

Constructs a new LocalFirstAvoidEvictionPolicy.

Parameters:

conf - Alluxio configuration

Method Detail

getWorker

public java.util.Optional<WorkerNetAddress> getWorker(GetWorkerOptions options)

Description copied from interface: BlockLocationPolicy

Gets the worker's network address for serving operations requested for the block.

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(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object