Spring for Apache Hadoop

org.springframework.yarn.batch.container
Class AbstractBatchYarnContainer

java.lang.Object
  extended by org.springframework.yarn.container.AbstractYarnContainer
      extended by org.springframework.yarn.integration.container.AbstractIntegrationYarnContainer
          extended by 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

Spring for Apache Hadoop