alluxio.client.block.policy

Class RoundRobinPolicy

java.lang.Object

alluxio.client.block.policy.RoundRobinPolicy

All Implemented Interfaces:

BlockLocationPolicy

@NotThreadSafe
public final class RoundRobinPolicy
extends java.lang.Object
implements BlockLocationPolicy

A policy that chooses the worker for the next block in a round-robin manner and skips workers that do not have enough space.

Nested Class Summary

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

BlockLocationPolicy.Factory

Constructor Summary

Constructors

Constructor and Description
RoundRobinPolicy(AlluxioConfiguration ignoredConf) Constructs a new RoundRobinPolicy.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.util.Optional<WorkerNetAddress>	getWorker(GetWorkerOptions options) The policy uses the first fetch of worker info list as the base, and visits each of them in a round-robin manner in the subsequent calls.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinPolicy

public RoundRobinPolicy(AlluxioConfiguration ignoredConf)

Constructs a new RoundRobinPolicy.

Parameters:

ignoredConf - unused, but needed for instantiation in BlockLocationPolicy.Factory

Method Detail

getWorker

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

The policy uses the first fetch of worker info list as the base, and visits each of them in a round-robin manner in the subsequent calls. The policy doesn't assume the list of worker info in the subsequent calls has the same order from the first, and it will skip the workers that are no longer active. Returns null if no worker can be found.

Specified by:

getWorker in interface BlockLocationPolicy

Parameters:

options - options

Returns:

the address of the worker to write to

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