org.springframework.yarn.am.container

Class DefaultContainerLauncher

java.lang.Object

org.springframework.yarn.support.LifecycleObjectSupport

org.springframework.yarn.am.container.AbstractLauncher

org.springframework.yarn.am.container.DefaultContainerLauncher

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ContainerLauncher

public class DefaultContainerLauncher
extends AbstractLauncher
implements ContainerLauncher

Default container launcher.

Author:

Janne Valkealahti

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.yarn.am.container.AbstractLauncher

AbstractLauncher.ContainerLauncherInterceptorList

Constructor Summary

Constructors

Constructor and Description
DefaultContainerLauncher()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart() Subclasses may implement this method with the start behavior.
protected void	doStop() Subclasses may implement this method with the stop behavior.
void	launchContainer(org.apache.hadoop.yarn.api.records.Container container, java.util.List<java.lang.String> commands) Launch container Container using given list of commands.
protected void	onInit() Subclasses may implement this for initialization logic.
protected void	setupLaunchContextTokens(org.apache.hadoop.yarn.api.records.ContainerLaunchContext ctx) Setup tokens for ContainerLaunchContext.

Methods inherited from class org.springframework.yarn.am.container.AbstractLauncher

addInterceptor, getCmTemplate, getConfiguration, getEnvironment, getInterceptors, getResourceLocalizer, setConfiguration, setEnvironment, setInterceptors, setResourceLocalizer

Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport

afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultContainerLauncher

public DefaultContainerLauncher()

Method Detail

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: LifecycleObjectSupport

Subclasses may implement this for initialization logic. Called during the InitializingBean phase. Implementor should always call super method not to break initialization chain.

Overrides:

onInit in class AbstractLauncher

Throws:

java.lang.Exception - exception

doStart

protected void doStart()

Description copied from class: LifecycleObjectSupport

Subclasses may implement this method with the start behavior. This method will be invoked while holding the LifecycleObjectSupport.lifecycleLock.

Overrides:

doStart in class LifecycleObjectSupport

doStop

protected void doStop()

Description copied from class: LifecycleObjectSupport

Subclasses may implement this method with the stop behavior. This method will be invoked while holding the LifecycleObjectSupport.lifecycleLock.

Overrides:

doStop in class LifecycleObjectSupport

launchContainer

public void launchContainer(org.apache.hadoop.yarn.api.records.Container container,
                   java.util.List<java.lang.String> commands)

Description copied from interface: ContainerLauncher

Launch container Container using given list of commands.

Specified by:

launchContainer in interface ContainerLauncher

Parameters:

container - the Container

commands - the list of commands

setupLaunchContextTokens

protected void setupLaunchContextTokens(org.apache.hadoop.yarn.api.records.ContainerLaunchContext ctx)

Setup tokens for ContainerLaunchContext.

Parameters:

ctx - the container launch context