alluxio.client.block.policy

Class SpecificHostPolicy

java.lang.Object

alluxio.client.block.policy.SpecificHostPolicy

All Implemented Interfaces:

BlockLocationPolicy

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

Always returns a worker with the hostname specified by PropertyKey.WORKER_HOSTNAME (alluxio.worker.hostname).

Nested Class Summary

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

BlockLocationPolicy.Factory

Constructor Summary

Constructors

Constructor and Description
SpecificHostPolicy(AlluxioConfiguration conf) Constructs a new SpecificHostPolicy needed for instantiation in BlockLocationPolicy.Factory.
SpecificHostPolicy(java.lang.String hostname) Constructs the policy with the hostname.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.util.Optional<WorkerNetAddress>	getWorker(GetWorkerOptions options) Returns null if no active worker matches the hostname provided in WORKER_HOSTNAME (alluxio.worker.hostname).
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificHostPolicy

public SpecificHostPolicy(AlluxioConfiguration conf)

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

Parameters:

conf - Alluxio configuration

SpecificHostPolicy

public SpecificHostPolicy(java.lang.String hostname)

Constructs the policy with the hostname.

Parameters:

hostname - the name of the host

Method Detail

getWorker

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

Returns null if no active worker matches the hostname provided in WORKER_HOSTNAME (alluxio.worker.hostname).

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