org.springframework.yarn.container

Class DefaultYarnContainer

java.lang.Object

org.springframework.yarn.support.LifecycleObjectSupport

org.springframework.yarn.container.AbstractYarnContainer

org.springframework.yarn.container.DefaultYarnContainer

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, LongRunningYarnContainer, YarnContainer, YarnContainerRuntime

public class DefaultYarnContainer
extends AbstractYarnContainer
implements org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>

Default implementation of a YarnContainer.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
DefaultYarnContainer()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStop() Subclasses may implement this method with the stop behavior.
boolean	isWaitCompleteState() Indication for possible handler using this bean whether it should wait COMPLETED state.
void	onApplicationEvent(org.springframework.context.event.ContextClosedEvent event)
protected void	runInternal() Internal method to handle the actual AbstractYarnContainer.run() method.

Methods inherited from class org.springframework.yarn.container.AbstractYarnContainer

addContainerStateListener, getConfiguration, getEnvironment, getEnvironment, getParameters, notifyCompleted, notifyCompleted, notifyContainerState, run, setConfiguration, setEnvironment, setParameters

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

afterPropertiesSet, doStart, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, 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

DefaultYarnContainer

public DefaultYarnContainer()

Method Detail

runInternal

protected void runInternal()

Description copied from class: AbstractYarnContainer

Internal method to handle the actual AbstractYarnContainer.run() method.

Specified by:

runInternal in class AbstractYarnContainer

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

isWaitCompleteState

public boolean isWaitCompleteState()

Description copied from interface: LongRunningYarnContainer

Indication for possible handler using this bean whether it should wait COMPLETED state.

Specified by:

isWaitCompleteState in interface LongRunningYarnContainer

Overrides:

isWaitCompleteState in class AbstractYarnContainer

Returns:

True if complete state should be wait

See Also:

LongRunningYarnContainer.addContainerStateListener(ContainerStateListener)

onApplicationEvent

public void onApplicationEvent(org.springframework.context.event.ContextClosedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>