org.apache.twill.internal

Class DefaultTwillRunResources

java.lang.Object

org.apache.twill.internal.DefaultTwillRunResources

All Implemented Interfaces:

TwillRunResources

public class DefaultTwillRunResources
extends Object
implements TwillRunResources

Straightforward implementation of TwillRunResources.

Constructor Summary

Constructors

Constructor and Description
DefaultTwillRunResources(int instanceId, String containerId, int cores, int memoryMB, int maxHeapMemoryMB, String host, Integer debugPort) Constructor to create an instance of DefaultTwillRunResources with empty log levels.
DefaultTwillRunResources(int instanceId, String containerId, int cores, int memoryMB, int maxHeapMemoryMB, String host, Integer debugPort, Map<String,LogEntry.Level> logLevels)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getContainerId()
Integer	getDebugPort()
String	getHost()
int	getInstanceId()
LogEntry.Level	getLogLevel() Deprecated.
Map<String,LogEntry.Level>	getLogLevels()
int	getMaxHeapMemoryMB()
int	getMemoryMB()
int	getVirtualCores()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTwillRunResources

public DefaultTwillRunResources(int instanceId,
                                String containerId,
                                int cores,
                                int memoryMB,
                                int maxHeapMemoryMB,
                                String host,
                                Integer debugPort)

Constructor to create an instance of DefaultTwillRunResources with empty log levels.

DefaultTwillRunResources

public DefaultTwillRunResources(int instanceId,
                                String containerId,
                                int cores,
                                int memoryMB,
                                int maxHeapMemoryMB,
                                String host,
                                Integer debugPort,
                                Map<String,LogEntry.Level> logLevels)

Method Detail

getInstanceId

public int getInstanceId()

Specified by:

getInstanceId in interface TwillRunResources

Returns:

instance id of the runnable.

getContainerId

public String getContainerId()

Specified by:

getContainerId in interface TwillRunResources

Returns:

id of the container the runnable is running in.

getVirtualCores

public int getVirtualCores()

Specified by:

getVirtualCores in interface TwillRunResources

Returns:

number of cores the runnable is allowed to use. YARN must be at least v2.1.0 and it must be configured to use cgroups in order for this to be a reflection of truth.

getMemoryMB

public int getMemoryMB()

Specified by:

getMemoryMB in interface TwillRunResources

Returns:

amount of memory in MB the runnable is allowed to use.

getMaxHeapMemoryMB

public int getMaxHeapMemoryMB()

Specified by:

getMaxHeapMemoryMB in interface TwillRunResources

Returns:

the maximum amount of memory in MB of Java process heap memory.

getHost

public String getHost()

Specified by:

getHost in interface TwillRunResources

Returns:

the host the runnable is running on.

getDebugPort

public Integer getDebugPort()

Specified by:

getDebugPort in interface TwillRunResources

Returns:

the debug port of the container's JVM, or null if not debug-enabled.

getLogLevel

@Deprecated
 @Nullable
public LogEntry.Level getLogLevel()

Deprecated.

Specified by:

getLogLevel in interface TwillRunResources

Returns:

the enabled log level for the container where the runnable is running in.

getLogLevels

public Map<String,LogEntry.Level> getLogLevels()

Specified by:

getLogLevels in interface TwillRunResources

Returns:

the enabled log level arguments for the container where the runnable is running in.

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