org.apache.reef.runtime.common.driver.api

Class ResourceRequestEventImpl

java.lang.Object

org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl

All Implemented Interfaces:

ResourceRequestEvent

public final class ResourceRequestEventImpl
extends Object
implements ResourceRequestEvent

Default POJO implementation of ResourceRequestEvent. Use newBuilder to construct an instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ResourceRequestEventImpl.Builder Builder used to create ResourceRequestEvent instances.

Method Summary

Methods

Modifier and Type	Method and Description
Optional<Integer>	getMemorySize()
List<String>	getNodeNameList()
Optional<Integer>	getPriority()
List<String>	getRackNameList()
Optional<Boolean>	getRelaxLocality()
int	getResourceCount()
String	getRuntimeName()
Optional<Integer>	getVirtualCores()
static ResourceRequestEventImpl.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Method Detail

getResourceCount

public int getResourceCount()

Specified by:

getResourceCount in interface ResourceRequestEvent

Returns:

The number of resources requested

getNodeNameList

public List<String> getNodeNameList()

Specified by:

getNodeNameList in interface ResourceRequestEvent

Returns:

A list of preferred nodes to place the resource on. An empty list indicates all nodes are equally preferred.

getRackNameList

public List<String> getRackNameList()

Specified by:

getRackNameList in interface ResourceRequestEvent

Returns:

A list of preferred racks to place the resource on, An empty list indicates all racks are equally preferred.

getMemorySize

public Optional<Integer> getMemorySize()

Specified by:

getMemorySize in interface ResourceRequestEvent

Returns:

The amount of memory to allocate to the resource

getPriority

public Optional<Integer> getPriority()

Specified by:

getPriority in interface ResourceRequestEvent

Returns:

The priority assigned to the resource

getVirtualCores

public Optional<Integer> getVirtualCores()

Specified by:

getVirtualCores in interface ResourceRequestEvent

Returns:

The number of virtual CPU cores to allocate for the resource

getRelaxLocality

public Optional<Boolean> getRelaxLocality()

Specified by:

getRelaxLocality in interface ResourceRequestEvent

Returns:

If true, allow allocation on nodes and racks other than the preferred list. If false, strictly enforce the preferences.

getRuntimeName

public String getRuntimeName()

Specified by:

getRuntimeName in interface ResourceRequestEvent

Returns:

The runtime name

newBuilder

public static ResourceRequestEventImpl.Builder newBuilder()