org.springframework.xd.yarn

Class XdAppmaster

java.lang.Object

org.springframework.yarn.support.LifecycleObjectSupport

org.springframework.yarn.am.AbstractAppmaster

org.springframework.yarn.am.AbstractServicesAppmaster

org.springframework.yarn.am.AbstractEventingAppmaster

org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster

org.springframework.yarn.am.cluster.ManagedContainerClusterAppmaster

org.springframework.xd.yarn.XdAppmaster

All Implemented Interfaces:

java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationListener<org.springframework.yarn.event.AbstractYarnEvent>, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.yarn.am.cluster.ContainerClusterAppmaster, org.springframework.yarn.am.YarnAppmaster

public class XdAppmaster
extends org.springframework.yarn.am.cluster.ManagedContainerClusterAppmaster

Custom application master handling XD containers grouping setting for launch commands.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
XdAppmaster()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.util.List<java.lang.String>	onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container, org.springframework.yarn.am.cluster.ContainerCluster cluster, java.util.List<java.lang.String> commands)

Methods inherited from class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster

createContainerCluster, createContainerCluster, destroyContainerCluster, doCreateGrid, doCreateProjectedGrid, doStart, doStop, getContainerClusters, handleSatisfyStateData, killContainer, modifyContainerCluster, onContainerAllocated, onContainerCompleted, onContainerLaunched, onInit, setGridProjectionFactoryLocator, setProjectionDataRegistry, setStateMachineFactory, startContainerCluster, stopContainerCluster, submitApplication

Methods inherited from class org.springframework.yarn.am.AbstractEventingAppmaster

getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, shutdownContainers

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, 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, setTemplate

Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport

afterPropertiesSet, 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

Constructor Detail

XdAppmaster

public XdAppmaster()

Method Detail

onContainerLaunchCommands

protected java.util.List<java.lang.String> onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container,
                                                         org.springframework.yarn.am.cluster.ContainerCluster cluster,
                                                         java.util.List<java.lang.String> commands)

Overrides:

onContainerLaunchCommands in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster