org.springframework.yarn.batch.container

Class DefaultBatchYarnContainer

java.lang.Object

org.springframework.yarn.support.LifecycleObjectSupport

org.springframework.yarn.container.AbstractYarnContainer

org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

org.springframework.yarn.batch.container.AbstractBatchYarnContainer

org.springframework.yarn.batch.container.DefaultBatchYarnContainer

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, LongRunningYarnContainer, YarnContainer, YarnContainerRuntime

public class DefaultBatchYarnContainer
extends AbstractBatchYarnContainer

Default implementation of AbstractBatchYarnContainer to handle Spring Batch remote steps.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
DefaultBatchYarnContainer()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	runInternal() Internal method to handle the actual AbstractYarnContainer.run() method.
void	setAppmasterServiceClient(AppmasterServiceClient appmasterServiceClient)

Methods inherited from class org.springframework.yarn.batch.container.AbstractBatchYarnContainer

getJobExplorer, getStepLocator, setJobExplorer, setStepLocator

Methods inherited from class org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer

getIntegrationServiceClient, setIntegrationServiceClient

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

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

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

afterPropertiesSet, doStart, doStop, 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

DefaultBatchYarnContainer

public DefaultBatchYarnContainer()

Method Detail

setAppmasterServiceClient

@Autowired(required=false)
public void setAppmasterServiceClient(AppmasterServiceClient appmasterServiceClient)

runInternal

protected void runInternal()

Description copied from class: AbstractYarnContainer

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

Specified by:

runInternal in class AbstractYarnContainer