|
|||||||||
| 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(StepExecution masterStepExecution,
String remoteStepName,
Set<StepExecution> stepExecutions,
Map<StepExecution,org.springframework.yarn.am.container.ContainerRequestHint> resourceRequests)
Adds the step splits. |
JobLauncher |
getJobLauncher()
Gets the job launcher. |
String |
getJobName()
Gets the job name. |
JobParametersConverter |
getJobParametersConverter()
Gets the job parameters converter. |
List<StepExecution> |
getStepExecutions()
Gets the step executions. |
protected void |
onContainerAllocated(Container container)
|
protected void |
onContainerCompleted(ContainerStatus status)
|
protected void |
onContainerLaunched(Container container)
|
protected void |
onInit()
|
ContainerLaunchContext |
preLaunch(Container container,
ContainerLaunchContext context)
|
void |
runJob(Job job)
Runs the given job. |
void |
setJobLauncher(JobLauncher jobLauncher)
Sets the job launcher. |
void |
setJobName(String jobName)
Sets the job name. |
void |
setJobParametersConverter(JobParametersConverter jobParametersConverter)
Injection setter for JobParametersConverter. |
| 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.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, 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 Exception
onInit in class org.springframework.yarn.am.AbstractAppmasterExceptionprotected void onContainerAllocated(Container container)
onContainerAllocated in class org.springframework.yarn.am.AbstractEventingAppmasterprotected void onContainerLaunched(Container container)
onContainerLaunched in class org.springframework.yarn.am.AbstractEventingAppmasterprotected void onContainerCompleted(ContainerStatus status)
onContainerCompleted in class org.springframework.yarn.am.AbstractEventingAppmaster
public ContainerLaunchContext preLaunch(Container container,
ContainerLaunchContext context)
preLaunch in interface org.springframework.yarn.am.ContainerLauncherInterceptorpublic void runJob(Job job)
job - the job to runpublic void addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener)
addPartitionedStepExecutionStateListener in interface BatchYarnAppmasterlistener - the listenerpublic JobLauncher getJobLauncher()
public void setJobLauncher(JobLauncher jobLauncher)
jobLauncher - the new job launcherpublic String getJobName()
public void setJobName(String jobName)
jobName - the new job namepublic List<StepExecution> getStepExecutions()
getStepExecutions in interface BatchYarnAppmaster
public void addStepSplits(StepExecution masterStepExecution,
String remoteStepName,
Set<StepExecution> stepExecutions,
Map<StepExecution,org.springframework.yarn.am.container.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 executionspublic JobParametersConverter getJobParametersConverter()
public void setJobParametersConverter(JobParametersConverter jobParametersConverter)
JobParametersConverter.
jobParametersConverter -
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||