org.apache.hadoop.yarn.client.api

Class AppAdminClient

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.client.api.AppAdminClient

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract class AppAdminClient
extends org.apache.hadoop.service.CompositeService

Client for managing applications.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_CLASS_NAME
static String	DEFAULT_TYPE
static String	UNIT_TEST_CLASS_NAME
static String	UNIT_TEST_TYPE
static String	YARN_APP_ADMIN_CLIENT_PREFIX

Fields inherited from class org.apache.hadoop.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AppAdminClient()

Method Summary

Modifier and Type	Method and Description
abstract int	actionDestroy(String appName) Remove the specification and all application data for a YARN application.
abstract int	actionFlex(String appName, Map<String,String> componentCounts) Change the number of running containers for a component of a YARN application / long-running service.
abstract int	actionLaunch(String fileName, String appName, Long lifetime, String queue) Launch a new YARN application.
abstract int	actionSave(String fileName, String appName, Long lifetime, String queue) Save the specification for a YARN application / long-running service.
abstract int	actionStart(String appName) Start a YARN application from a previously saved specification.
abstract int	actionStop(String appName) Stop a YARN application (attempt to stop gracefully before killing the application).
static AppAdminClient	createAppAdminClient(String appType, org.apache.hadoop.conf.Configuration conf) Create a new instance of AppAdminClient.
abstract int	enableFastLaunch(String destinationFolder) Upload AM dependencies to HDFS.
abstract String	getStatusString(String appIdOrName) Get detailed app specific status string for a YARN application.

Methods inherited from class org.apache.hadoop.service.CompositeService

addIfService, addService, getServices, removeService, serviceInit, serviceStart, serviceStop

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

YARN_APP_ADMIN_CLIENT_PREFIX

public static final String YARN_APP_ADMIN_CLIENT_PREFIX

See Also:

Constant Field Values

DEFAULT_TYPE

public static final String DEFAULT_TYPE

See Also:

Constant Field Values

DEFAULT_CLASS_NAME

public static final String DEFAULT_CLASS_NAME

See Also:

Constant Field Values

UNIT_TEST_TYPE

public static final String UNIT_TEST_TYPE

See Also:

Constant Field Values

UNIT_TEST_CLASS_NAME

public static final String UNIT_TEST_CLASS_NAME

See Also:

Constant Field Values

Constructor Detail

AppAdminClient

@InterfaceAudience.Private
protected AppAdminClient()

Method Detail

createAppAdminClient

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public static AppAdminClient createAppAdminClient(String appType,
                                                                                                          org.apache.hadoop.conf.Configuration conf)

Create a new instance of AppAdminClient.

Parameters:

appType - application type

conf - configuration

Returns:

app admin client

actionLaunch

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionLaunch(String fileName,
                                                                                         String appName,
                                                                                         Long lifetime,
                                                                                         String queue)
                                                                                  throws IOException,
                                                                                         org.apache.hadoop.yarn.exceptions.YarnException

Launch a new YARN application.

Parameters:

fileName - specification of application

appName - name of the application

lifetime - lifetime of the application

queue - queue of the application

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

actionStop

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionStop(String appName)
                                                                                throws IOException,
                                                                                       org.apache.hadoop.yarn.exceptions.YarnException

Stop a YARN application (attempt to stop gracefully before killing the application). In the case of a long-running service, the service may be restarted later.

Parameters:

appName - the name of the application

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

actionStart

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionStart(String appName)
                                                                                 throws IOException,
                                                                                        org.apache.hadoop.yarn.exceptions.YarnException

Start a YARN application from a previously saved specification. In the case of a long-running service, the service must have been previously launched/started and then stopped, or previously saved but not started.

Parameters:

appName - the name of the application

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

actionSave

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionSave(String fileName,
                                                                                       String appName,
                                                                                       Long lifetime,
                                                                                       String queue)
                                                                                throws IOException,
                                                                                       org.apache.hadoop.yarn.exceptions.YarnException

Save the specification for a YARN application / long-running service. The application may be started later.

Parameters:

fileName - specification of application to save

appName - name of the application

lifetime - lifetime of the application

queue - queue of the application

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

actionDestroy

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionDestroy(String appName)
                                                                                   throws IOException,
                                                                                          org.apache.hadoop.yarn.exceptions.YarnException

Remove the specification and all application data for a YARN application. The application cannot be running.

Parameters:

appName - the name of the application

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

actionFlex

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int actionFlex(String appName,
                                                                                       Map<String,String> componentCounts)
                                                                                throws IOException,
                                                                                       org.apache.hadoop.yarn.exceptions.YarnException

Change the number of running containers for a component of a YARN application / long-running service.

Parameters:

appName - the name of the application

componentCounts - map of component name to new component count or amount to change existing component count (e.g. 5, +5, -5)

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

enableFastLaunch

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract int enableFastLaunch(String destinationFolder)
                                                                                      throws IOException,
                                                                                             org.apache.hadoop.yarn.exceptions.YarnException

Upload AM dependencies to HDFS. This makes future application launches faster since the dependencies do not have to be uploaded on each launch.

Parameters:

destinationFolder - an optional HDFS folder where dependency tarball will be uploaded

Returns:

exit code

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server

getStatusString

@InterfaceAudience.Public
 @InterfaceStability.Unstable
public abstract String getStatusString(String appIdOrName)
                                                                                        throws IOException,
                                                                                               org.apache.hadoop.yarn.exceptions.YarnException

Get detailed app specific status string for a YARN application.

Parameters:

appIdOrName - appId or appName

Returns:

status string

Throws:

IOException - IOException

org.apache.hadoop.yarn.exceptions.YarnException - exception in client or server