public abstract class AbstractBatchAppmaster extends org.springframework.yarn.am.AbstractEventingAppmaster implements BatchYarnAppmaster, org.springframework.yarn.am.ContainerLauncherInterceptor
| Constructor and Description |
|---|
AbstractBatchAppmaster() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
List<StepExecution> |
getStepExecutions()
Gets the step executions.
|
YarnJobLauncher |
getYarnJobLauncher() |
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 |
setYarnJobLauncher(YarnJobLauncher yarnJobLauncher) |
getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, shutdownContainersgetAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitoraddAppmasterStateListener, doStop, finishAppmaster, getApplicationAttemptId, getAppmasterClientService, getAppmasterService, getAppmasterTrackService, getCmTemplate, getCommands, getCommands, getConfiguration, getContainerAssign, getContainerShutdown, getEnvironment, getEnvironment, getParameters, getResourceLocalizer, getTemplate, notifyCompleted, registerAppmaster, setCommands, setCommands, setCommands, setCommands, setConfiguration, setContainerAssign, setEnvironment, setEnvironment, setFinalApplicationStatus, setParameters, setResourceLocalizer, setTemplateafterPropertiesSet, doStart, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stopprotected void onInit()
throws Exception
onInit in class org.springframework.yarn.am.AbstractEventingAppmasterExceptionprotected 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.AbstractEventingAppmasterpublic ContainerLaunchContext preLaunch(Container container, ContainerLaunchContext context)
preLaunch in interface org.springframework.yarn.am.ContainerLauncherInterceptor@Autowired(required=false) public void setYarnJobLauncher(YarnJobLauncher yarnJobLauncher)
public YarnJobLauncher getYarnJobLauncher()
public void addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener)
addPartitionedStepExecutionStateListener in interface BatchYarnAppmasterlistener - the listenerpublic List<StepExecution> getStepExecutions()
getStepExecutions in interface BatchYarnAppmasterpublic 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 executions