alluxio.client.file.policy

Class SpecificHostPolicy

java.lang.Object

alluxio.client.file.policy.SpecificHostPolicy

All Implemented Interfaces:

BlockLocationPolicy, FileWriteLocationPolicy

@ThreadSafe
public final class SpecificHostPolicy
extends Object
implements FileWriteLocationPolicy, BlockLocationPolicy

Always returns a worker with the specified hostname. Returns null if no active worker on that hostname found.

Nested Class Summary

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

BlockLocationPolicy.Factory

Constructor Summary

Constructors

Constructor and Description
SpecificHostPolicy(String hostname) Constructs the policy with the hostname.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
WorkerNetAddress	getWorker(GetWorkerOptions options) Gets the worker's network address for serving operations requested for the block.
WorkerNetAddress	getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes) Gets the worker's host name for the next block to write to.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificHostPolicy

public SpecificHostPolicy(String hostname)

Constructs the policy with the hostname.

Parameters:

hostname - the name of the host

Method Detail

getWorkerForNextBlock

public WorkerNetAddress getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList,
                                              long blockSizeBytes)

Description copied from interface: FileWriteLocationPolicy

Gets the worker's host name for the next block to write to.

Specified by:

getWorkerForNextBlock in interface FileWriteLocationPolicy

Parameters:

workerInfoList - the info of the active workers

blockSizeBytes - the size of the block in bytes

Returns:

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

getWorker

public 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, null 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