org.apache.reef.runtime.yarn.util

Class YarnTypes

java.lang.Object

org.apache.reef.runtime.yarn.util.YarnTypes

public final class YarnTypes
extends Object

Helper class that creates the various records in the YARN API.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MIN_VERSION_KEEP_CONTAINERS_AVAILABLE

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.yarn.api.records.ContainerLaunchContext	getContainerLaunchContext(List<String> commands, Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources, byte[] securityTokenBuffer)
static org.apache.hadoop.yarn.api.records.ContainerLaunchContext	getContainerLaunchContext(List<String> commands, Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources, byte[] securityTokenBuffer, org.apache.hadoop.yarn.api.records.ApplicationId applicationId) Gets a LaunchContext and sets the environment variable YarnUtilities.REEF_YARN_APPLICATION_ID_ENV_VAR for REEF Evaluators.
static boolean	isAtOrAfterVersion(String version)

Methods inherited from class java.lang.Object

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

Field Detail

MIN_VERSION_KEEP_CONTAINERS_AVAILABLE

public static final String MIN_VERSION_KEEP_CONTAINERS_AVAILABLE

See Also:

Constant Field Values

Method Detail

getContainerLaunchContext

public static org.apache.hadoop.yarn.api.records.ContainerLaunchContext getContainerLaunchContext(List<String> commands,
                                                                                  Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources,
                                                                                  byte[] securityTokenBuffer)

Returns:

a ContainerLaunchContext with the given commands and LocalResources.

getContainerLaunchContext

public static org.apache.hadoop.yarn.api.records.ContainerLaunchContext getContainerLaunchContext(List<String> commands,
                                                                                  Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources,
                                                                                  byte[] securityTokenBuffer,
                                                                                  org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

Gets a LaunchContext and sets the environment variable YarnUtilities.REEF_YARN_APPLICATION_ID_ENV_VAR for REEF Evaluators.

Returns:

a ContainerLaunchContext with the given commands and LocalResources.

isAtOrAfterVersion

public static boolean isAtOrAfterVersion(String version)