org.springframework.yarn.batch.am
Class BatchAppmaster

java.lang.Object
  extended by org.springframework.yarn.support.LifecycleObjectSupport
      extended by org.springframework.yarn.am.AbstractAppmaster
          extended by org.springframework.yarn.am.AbstractServicesAppmaster
              extended by org.springframework.yarn.am.AbstractEventingAppmaster
                  extended by org.springframework.yarn.batch.am.AbstractBatchAppmaster
                      extended by org.springframework.yarn.batch.am.BatchAppmaster
All Implemented Interfaces:
EventListener, Aware, BeanFactoryAware, InitializingBean, ApplicationListener<org.springframework.yarn.event.AbstractYarnEvent>, Lifecycle, Phased, SmartLifecycle, org.springframework.yarn.am.ContainerLauncherInterceptor, org.springframework.yarn.am.YarnAppmaster, BatchYarnAppmaster

public class BatchAppmaster
extends AbstractBatchAppmaster
implements org.springframework.yarn.am.YarnAppmaster

Implementation of application master which can be used to run Spring Batch jobs on Hadoop Yarn cluster.

Application master will act as a context running the Spring Batch job. Order to make some sense in terms of using cluster resources, job itself should be able to partition itself in a way that Yarn containers can be used to split the load.

Author:
Janne Valkealahti

Constructor Summary
BatchAppmaster()
           
 
Method Summary
protected  void doStart()
           
 void onApplicationEvent(org.springframework.yarn.event.AbstractYarnEvent event)
           
 void submitApplication()
           
 
Methods inherited from class org.springframework.yarn.batch.am.AbstractBatchAppmaster
addPartitionedStepExecutionStateListener, addStepSplits, getStepExecutions, getYarnJobLauncher, onContainerAllocated, onContainerCompleted, onContainerLaunched, onInit, preLaunch, setYarnJobLauncher
 
Methods inherited from class org.springframework.yarn.am.AbstractEventingAppmaster
onContainerLaunchRequestFailed
 
Methods inherited from class org.springframework.yarn.am.AbstractServicesAppmaster
getAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitor
 
Methods inherited from class org.springframework.yarn.am.AbstractAppmaster
addAppmasterStateListener, doStop, finishAppmaster, getApplicationAttemptId, getAppmasterClientService, getAppmasterService, getAppmasterTrackService, getCommands, getConfiguration, getContainerAssign, getEnvironment, getParameters, getResourceLocalizer, getTemplate, notifyCompleted, registerAppmaster, setCommands, setCommands, setConfiguration, setContainerAssign, setEnvironment, setFinalApplicationStatus, setParameters, setResourceLocalizer, setTemplate
 
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
 
Methods inherited from interface org.springframework.yarn.am.YarnAppmaster
addAppmasterStateListener, setEnvironment, setParameters
 

Constructor Detail

BatchAppmaster

public BatchAppmaster()
Method Detail

submitApplication

public void submitApplication()
Specified by:
submitApplication in interface org.springframework.yarn.am.YarnAppmaster

onApplicationEvent

public void onApplicationEvent(org.springframework.yarn.event.AbstractYarnEvent event)
Specified by:
onApplicationEvent in interface ApplicationListener<org.springframework.yarn.event.AbstractYarnEvent>
Overrides:
onApplicationEvent in class org.springframework.yarn.am.AbstractEventingAppmaster

doStart

protected void doStart()
Overrides:
doStart in class org.springframework.yarn.support.LifecycleObjectSupport