public class StreamAppmaster
extends org.springframework.yarn.am.cluster.ManagedContainerClusterAppmaster
Constructor and Description |
---|
StreamAppmaster() |
Modifier and Type | Method and Description |
---|---|
protected Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
buildLocalizedResources(org.springframework.yarn.am.cluster.ContainerCluster cluster) |
org.springframework.yarn.am.cluster.ContainerCluster |
createContainerCluster(String clusterId,
String clusterDef,
org.springframework.yarn.am.grid.support.ProjectionData projectionData,
Map<String,Object> extraProperties) |
protected void |
onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status) |
protected List<String> |
onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container,
org.springframework.yarn.am.cluster.ContainerCluster cluster,
List<String> commands) |
protected void |
onInit() |
createContainerCluster, destroyContainerCluster, doCreateGrid, doCreateProjectedGrid, doStart, doStop, getContainerClusters, handleSatisfyStateData, killContainer, modifyContainerCluster, onContainerAllocated, onContainerLaunched, setGridProjectionFactoryLocator, setProjectionDataRegistry, setStateMachineFactory, startContainerCluster, stopContainerCluster, submitApplication
getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, shutdownContainers
getAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitor
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
afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
protected void onInit() throws Exception
onInit
in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
Exception
public org.springframework.yarn.am.cluster.ContainerCluster createContainerCluster(String clusterId, String clusterDef, org.springframework.yarn.am.grid.support.ProjectionData projectionData, Map<String,Object> extraProperties)
createContainerCluster
in interface org.springframework.yarn.am.cluster.ContainerClusterAppmaster
createContainerCluster
in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
protected List<String> onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container, org.springframework.yarn.am.cluster.ContainerCluster cluster, List<String> commands)
onContainerLaunchCommands
in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
protected Map<String,org.apache.hadoop.yarn.api.records.LocalResource> buildLocalizedResources(org.springframework.yarn.am.cluster.ContainerCluster cluster)
buildLocalizedResources
in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
onContainerCompleted
in class org.springframework.yarn.am.cluster.AbstractContainerClusterAppmaster
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.