|
Spring for Apache Hadoop | ||||||||
| 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(org.apache.hadoop.yarn.api.records.Container container)
Called when container has been allocated. |
protected void |
onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
Called when container has been completed. |
protected void |
onInit()
Global application master instance specific ApplicationAttemptId
is build during this init method. |
org.apache.hadoop.yarn.api.records.ContainerLaunchContext |
preLaunch(org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.yarn.api.records.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 java.lang.Exception
AbstractAppmasterApplicationAttemptId
is build during this init method.
onInit in class AbstractAppmasterjava.lang.Exception - exceptionLifecycleObjectSupport.onInit()
public org.apache.hadoop.yarn.api.records.ContainerLaunchContext preLaunch(org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext context)
ContainerLauncherInterceptorContainerLaunchContext is used
to launch the container.
preLaunch in interface ContainerLauncherInterceptorcontainer - the Containercontext - the ContainerLaunchContext
ContainerLaunchContextprotected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
container - the containerprotected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
status - the status
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||