public class BatchAppmaster extends AbstractBatchAppmaster implements org.springframework.yarn.am.YarnAppmaster
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.
| Constructor and Description |
|---|
BatchAppmaster() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
void |
onApplicationEvent(org.springframework.yarn.event.AbstractYarnEvent event) |
void |
submitApplication() |
addPartitionedStepExecutionStateListener, addStepSplits, getStepExecutions, getYarnJobLauncher, onContainerAllocated, onContainerCompleted, onContainerLaunched, onInit, preLaunch, setYarnJobLauncheronContainerLaunchRequestFailedgetAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitoraddAppmasterStateListener, doStop, finishAppmaster, getApplicationAttemptId, getAppmasterClientService, getAppmasterService, getAppmasterTrackService, getCommands, getConfiguration, getContainerAssign, getEnvironment, getParameters, getResourceLocalizer, getTemplate, notifyCompleted, registerAppmaster, setCommands, setCommands, setConfiguration, setContainerAssign, setEnvironment, setFinalApplicationStatus, setParameters, setResourceLocalizer, setTemplateafterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stoppublic void submitApplication()
submitApplication in interface org.springframework.yarn.am.YarnAppmasterpublic void onApplicationEvent(org.springframework.yarn.event.AbstractYarnEvent event)
onApplicationEvent in interface ApplicationListener<org.springframework.yarn.event.AbstractYarnEvent>onApplicationEvent in class org.springframework.yarn.am.AbstractEventingAppmasterprotected void doStart()
doStart in class org.springframework.yarn.support.LifecycleObjectSupport