org.springframework.yarn.batch.container
Class AbstractBatchYarnContainer

java.lang.Object
  org.springframework.yarn.container.AbstractYarnContainer
      org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer
          org.springframework.yarn.batch.container.AbstractBatchYarnContainer

All Implemented Interfaces:

LongRunningYarnContainer, YarnContainer, YarnContainerRuntime

Direct Known Subclasses:

DefaultBatchYarnContainer

public abstract class AbstractBatchYarnContainer
extends AbstractIntegrationYarnContainer

Base implementation of YarnContainer extending AbstractIntegrationYarnContainer adding functionality for Spring Batch.

Author:

Janne Valkealahti

Constructor Summary

AbstractBatchYarnContainer()

Method Summary

org.springframework.batch.core.explore.JobExplorer	getJobExplorer() Gets the job explorer.
org.springframework.batch.core.step.StepLocator	getStepLocator() Gets the step locator.
void	setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer) Sets the job explorer.
void	setStepLocator(org.springframework.batch.core.step.StepLocator stepLocator) Sets the step locator.

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, runInternal, setConfiguration, setEnvironment, setParameters

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractBatchYarnContainer

public AbstractBatchYarnContainer()

Method Detail

getStepLocator

public org.springframework.batch.core.step.StepLocator getStepLocator()

Gets the step locator.

Returns:

the step locator

setStepLocator

@Autowired(required=false)
public void setStepLocator(org.springframework.batch.core.step.StepLocator stepLocator)

Sets the step locator.

Parameters:

stepLocator - the new step locator

getJobExplorer

public org.springframework.batch.core.explore.JobExplorer getJobExplorer()

Gets the job explorer.

Returns:

the job explorer

setJobExplorer

@Autowired(required=false)
public void setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)

Sets the job explorer.

Parameters:

jobExplorer - the new job explorer