alluxio.stress.cli.client

Class ClientIOWritePolicy

java.lang.Object

alluxio.stress.cli.client.ClientIOWritePolicy

All Implemented Interfaces:

BlockLocationPolicy

@NotThreadSafe
public final class ClientIOWritePolicy
extends Object
implements BlockLocationPolicy

A write type for restricting the writes to a set number of workers. This should only be used for testing and benchmarking.

Nested Class Summary

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

BlockLocationPolicy.Factory

Constructor Summary

Constructors

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

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.
int	hashCode()
static void	setMaxWorkers(int maxWorkers) Updates the global state to reflect the max number of workers to write to.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientIOWritePolicy

public ClientIOWritePolicy(AlluxioConfiguration conf)

Constructs a new ClientIOWritePolicy.

Parameters:

conf - Alluxio configuration

Method Detail

setMaxWorkers

public static void setMaxWorkers(int maxWorkers)

Updates the global state to reflect the max number of workers to write to. This must be set before writes are performed to take effect.

Parameters:

maxWorkers - the max number of workers to write to

getWorker

@Nullable
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 - options

Returns:

the address of the worker to write to

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