|
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.AbstractEventingAppmaster
org.springframework.yarn.batch.am.AbstractBatchAppmaster
public abstract class AbstractBatchAppmaster
Base application master for running batch jobs.
| Constructor Summary | |
|---|---|
AbstractBatchAppmaster()
|
|
| Method Summary | |
|---|---|
void |
addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener)
Adds the partitioned step execution state listener. |
void |
addStepSplits(org.springframework.batch.core.StepExecution masterStepExecution,
java.lang.String remoteStepName,
java.util.Set<org.springframework.batch.core.StepExecution> stepExecutions,
java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests)
Adds the step splits. |
java.util.List<org.springframework.batch.core.StepExecution> |
getStepExecutions()
Gets the step executions. |
YarnJobLauncher |
getYarnJobLauncher()
|
protected void |
onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
Invoked when ContainerAllocationEvent is received as an
application event. |
protected void |
onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
Invoked when ContainerCompletedEvent is received as an
application event. |
protected void |
onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)
Invoked when ContainerLaunchedEvent is received as an
application event. |
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. |
void |
setYarnJobLauncher(YarnJobLauncher yarnJobLauncher)
|
| Methods inherited from class org.springframework.yarn.am.AbstractEventingAppmaster |
|---|
onApplicationEvent, onContainerLaunchRequestFailed |
| 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 |
| Methods inherited from interface org.springframework.yarn.am.YarnAppmaster |
|---|
addAppmasterStateListener, setEnvironment, setParameters, submitApplication |
| Constructor Detail |
|---|
public AbstractBatchAppmaster()
| Method Detail |
|---|
protected void onInit()
throws java.lang.Exception
AbstractAppmasterApplicationAttemptId
is build during this init method.
onInit in class AbstractAppmasterjava.lang.Exception - exceptionLifecycleObjectSupport.onInit()protected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmasterContainerAllocationEvent is received as an
application event. Wrapped Container is passed to a method.
onContainerAllocated in class AbstractEventingAppmastercontainer - the containerprotected void onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmasterContainerLaunchedEvent is received as an
application event. Wrapped Container is passed to a method.
onContainerLaunched in class AbstractEventingAppmastercontainer - the containerprotected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
AbstractEventingAppmasterContainerCompletedEvent is received as an
application event. Wrapped ContainerStatus is passed to a method.
onContainerCompleted in class AbstractEventingAppmasterstatus - the container status
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
ContainerLaunchContext@Autowired(required=false) public void setYarnJobLauncher(YarnJobLauncher yarnJobLauncher)
public YarnJobLauncher getYarnJobLauncher()
public void addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener)
addPartitionedStepExecutionStateListener in interface BatchYarnAppmasterlistener - the listenerpublic java.util.List<org.springframework.batch.core.StepExecution> getStepExecutions()
getStepExecutions in interface BatchYarnAppmaster
public void addStepSplits(org.springframework.batch.core.StepExecution masterStepExecution,
java.lang.String remoteStepName,
java.util.Set<org.springframework.batch.core.StepExecution> stepExecutions,
java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests)
addStepSplits in interface BatchYarnAppmastermasterStepExecution - the partitioned steps parent step executionremoteStepName - the remote step namestepExecutions - the step executions splitsresourceRequests - the request data for step executions
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||