org.apache.reef.driver.evaluator

Class EvaluatorRequest.Builder<T extends EvaluatorRequest.Builder>

java.lang.Object

org.apache.reef.driver.evaluator.EvaluatorRequest.Builder<T>

All Implemented Interfaces:

Builder<EvaluatorRequest>

Direct Known Subclasses:

EvaluatorRequestorImpl.Builder

Enclosing class:

EvaluatorRequest

public static class EvaluatorRequest.Builder<T extends EvaluatorRequest.Builder>
extends Object
implements Builder<EvaluatorRequest>

EvaluatorRequests are build using this Builder.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
T	addNodeName(String nodeName) Adds a node name.It is the preferred location where the evaluator should run on.
T	addRackName(String rackName) Adds a rack name.
EvaluatorRequest	build() Builds the EvaluatorRequest.
T	setMemory(int megaBytes) Set the amount of memory.
T	setNumber(int n) Set the number of Evaluators requested.
T	setNumberOfCores(int cores) Set number of cores.
T	setRuntimeName(String runtimeName) Set the name of the desired runtime.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

setMemory

public T setMemory(int megaBytes)

Set the amount of memory.

Parameters:

megaBytes - the amount of megabytes to request for the Evaluator.

Returns:

this builder

setRuntimeName

public T setRuntimeName(String runtimeName)

Set the name of the desired runtime.

Parameters:

runtimeName - to request for the Evaluator.

Returns:

this builder

setNumberOfCores

public T setNumberOfCores(int cores)

Set number of cores.

Parameters:

cores - the number of cores

Returns:

this Builder.

setNumber

public T setNumber(int n)

Set the number of Evaluators requested.

Parameters:

n - the number of evaluators

Returns:

this Builder.

addNodeName

public T addNodeName(String nodeName)

Adds a node name.It is the preferred location where the evaluator should run on. If the node is available, the RM will try to allocate the evaluator there

Parameters:

nodeName - a preferred node name

Returns:

this Builder.

addRackName

public T addRackName(String rackName)

Adds a rack name. It is the preferred location where the evaluator should run on. If the rack is available, the RM will try to allocate the evaluator in one of its nodes. The RM will try to match node names first, and then fallback to rack names

Parameters:

rackName - a preferred rack name

Returns:

this Builder.

build

public EvaluatorRequest build()

Builds the EvaluatorRequest.

Specified by:

build in interface Builder<EvaluatorRequest>

Returns:

a fresh instance of the object.