|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.support.LifecycleObjectSupport
org.springframework.yarn.am.AbstractAppmaster
org.springframework.yarn.am.AbstractServicesAppmaster
org.springframework.yarn.am.AbstractProcessingAppmaster
public abstract class AbstractProcessingAppmaster
Base application master implementation which handles a simple life-cycle scenario of; allocate, launch, monitor.
We can say that the actual implementation of this is very static in terms of what application master can do. Everything needs to be known prior to starting the life-cycle. Implementation should know how many containers will participate the application, what those containers will do and what is the expected outcome from a container execution.
| Constructor Summary | |
|---|---|
AbstractProcessingAppmaster()
|
|
| Method Summary | |
|---|---|
protected void |
onContainerAllocated(Container container)
Called when container has been allocated. |
protected void |
onContainerCompleted(ContainerStatus status)
Called when container has been completed. |
protected void |
onInit()
Global application master instance specific ApplicationAttemptId
is build during this init method. |
ContainerLaunchContext |
preLaunch(Container container,
ContainerLaunchContext context)
Invoked before the ContainerLaunchContext is used
to launch the container. |
| Methods inherited from class org.springframework.yarn.am.AbstractServicesAppmaster |
|---|
getAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitor |
| Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport |
|---|
afterPropertiesSet, doStart, 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 |
| Constructor Detail |
|---|
public AbstractProcessingAppmaster()
| Method Detail |
|---|
protected void onInit()
throws Exception
AbstractAppmasterApplicationAttemptId
is build during this init method.
onInit in class AbstractAppmasterExceptionLifecycleObjectSupport.onInit()
public ContainerLaunchContext preLaunch(Container container,
ContainerLaunchContext context)
ContainerLauncherInterceptorContainerLaunchContext is used
to launch the container.
preLaunch in interface ContainerLauncherInterceptorcontainer - the Containercontext - the ContainerLaunchContext
ContainerLaunchContextprotected void onContainerAllocated(Container container)
container - the containerprotected void onContainerCompleted(ContainerStatus status)
status - the status
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||