org.springframework.yarn.am
Class StaticAppmaster
java.lang.Object
org.springframework.yarn.support.LifecycleObjectSupport
org.springframework.yarn.am.AbstractAppmaster
org.springframework.yarn.am.AbstractServicesAppmaster
org.springframework.yarn.am.AbstractProcessingAppmaster
org.springframework.yarn.am.StaticAppmaster
- All Implemented Interfaces:
- Aware, BeanFactoryAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, ContainerLauncherInterceptor, YarnAppmaster
public class StaticAppmaster
- extends AbstractProcessingAppmaster
- implements YarnAppmaster
A simple application master implementation which will allocate
and launch a number of containers, monitor container statuses
and finally exit the application by sending corresponding
message back to resource manager.
- Author:
- Janne Valkealahti
|
Method Summary |
protected void |
doStart()
Subclasses may implement this method with the start behavior. |
protected void |
onInit()
Global application master instance specific ApplicationAttemptId
is build during this init method. |
void |
submitApplication()
Submit and run application. |
| 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 |
StaticAppmaster
public StaticAppmaster()
submitApplication
public void submitApplication()
- Description copied from interface:
YarnAppmaster
- Submit and run application.
- Specified by:
submitApplication in interface YarnAppmaster
onInit
protected void onInit()
throws Exception
- Description copied from class:
AbstractAppmaster
- Global application master instance specific
ApplicationAttemptId
is build during this init method.
- Overrides:
onInit in class AbstractProcessingAppmaster
- Throws:
Exception - exception- See Also:
LifecycleObjectSupport.onInit()
doStart
protected void doStart()
- Description copied from class:
LifecycleObjectSupport
- Subclasses may implement this method with the start behavior. This
method will be invoked while holding the
LifecycleObjectSupport.lifecycleLock.
- Overrides:
doStart in class LifecycleObjectSupport