public abstract class AbstractContainerClusterAppmaster extends AbstractEventingAppmaster implements ContainerClusterAppmaster
ContainerClusterAppmaster の基本実装。| コンストラクターと説明 |
|---|
AbstractContainerClusterAppmaster() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> | buildLocalizedResources(ContainerCluster cluster) |
ContainerCluster | createContainerCluster(java.lang.String clusterId, ProjectionData projectionData) |
ContainerCluster | createContainerCluster(java.lang.String clusterId, java.lang.String clusterDef, ProjectionData projectionData, java.util.Map<java.lang.String,java.lang.Object> extraProperties) |
void | destroyContainerCluster(java.lang.String id) |
protected Grid | doCreateGrid() |
protected ProjectedGrid | doCreateProjectedGrid(Grid grid) |
protected void | doStart() サブクラスは、開始動作でこのメソッドを実装できます。 |
protected void | doStop() サブクラスは、停止動作でこのメソッドを実装できます。 |
java.util.Map<java.lang.String,ContainerCluster> | getContainerClusters() |
protected void | handleSatisfyStateData(ContainerCluster cluster, SatisfyStateData satisfyData) |
protected void | killContainer(org.apache.hadoop.yarn.api.records.Container container) |
void | modifyContainerCluster(java.lang.String id, ProjectionData data) |
protected void | onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)ContainerAllocationEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
protected void | onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)ContainerCompletedEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
protected java.util.List<java.lang.String> | onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container, ContainerCluster cluster, java.util.List<java.lang.String> commands) サブクラスがこれらのコマンドの最終的な変更を行うためにコンテナーが起動されるときに呼び出されます。 |
protected void | onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)ContainerLaunchedEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
protected void | onInit() この init メソッド中に、グローバルアプリケーションマスターインスタンス固有の ApplicationAttemptId が構築されます。 |
void | setGridProjectionFactoryLocator(GridProjectionFactoryLocator gridProjectionFactoryLocator)GridProjection のインスタンスを作成するファクトリを検索するために使用される GridProjectionFactoryLocator を設定します。 |
void | setProjectionDataRegistry(ProjectionDataRegistry projectionDataRegistry) |
void | setStateMachineFactory(org.springframework.statemachine.config.StateMachineFactory<ClusterState, ClusterEvent> stateMachineFactory) |
void | startContainerCluster(java.lang.String id) |
void | stopContainerCluster(java.lang.String id) |
void | submitApplication() アプリケーションを送信して実行します。 |
getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, shutdownContainersgetAllocator, getLauncher, getMonitor, setAllocator, setLauncher, setMonitoraddAppmasterStateListener, 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, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddAppmasterStateListener, setEnvironment, setParametersprotected void onInit()
throws java.lang.ExceptionAbstractAppmasterApplicationAttemptId が構築されます。AbstractEventingAppmaster の onInit java.lang.Exception - 例外 LifecycleObjectSupport.onInit()protected void doStart()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。LifecycleObjectSupport の doStart protected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。AbstractAppmaster の doStop public void submitApplication()
YarnAppmasterYarnAppmaster 内の submitApplication protected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmasterContainerAllocationEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container がメソッドに渡されます。AbstractEventingAppmaster の onContainerAllocated container - コンテナー protected void onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmasterContainerLaunchedEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container がメソッドに渡されます。AbstractEventingAppmaster の onContainerLaunched container - コンテナー protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
AbstractEventingAppmasterContainerCompletedEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた ContainerStatus がメソッドに渡されます。AbstractEventingAppmaster の onContainerCompleted status - コンテナーの状態 public java.util.Map<java.lang.String,ContainerCluster> getContainerClusters()
ContainerClusterAppmaster 内の getContainerClusters public ContainerCluster createContainerCluster(java.lang.String clusterId, ProjectionData projectionData)
ContainerClusterAppmaster 内の createContainerCluster public ContainerCluster createContainerCluster(java.lang.String clusterId, java.lang.String clusterDef, ProjectionData projectionData, java.util.Map<java.lang.String,java.lang.Object> extraProperties)
ContainerClusterAppmaster 内の createContainerCluster public void startContainerCluster(java.lang.String id)
ContainerClusterAppmaster 内の startContainerCluster public void stopContainerCluster(java.lang.String id)
ContainerClusterAppmaster 内の stopContainerCluster public void destroyContainerCluster(java.lang.String id)
ContainerClusterAppmaster 内の destroyContainerCluster public void modifyContainerCluster(java.lang.String id,
ProjectionData data)ContainerClusterAppmaster 内の modifyContainerCluster @Autowired public void setStateMachineFactory(org.springframework.statemachine.config.StateMachineFactory<ClusterState,ClusterEvent> stateMachineFactory)
@Autowired public void setGridProjectionFactoryLocator(GridProjectionFactoryLocator gridProjectionFactoryLocator)
GridProjection のインスタンスを作成するファクトリを検索するために使用される GridProjectionFactoryLocator を設定します。gridProjectionFactoryLocator - グリッド射影ファクトリロケーター @Autowired(required=false) public void setProjectionDataRegistry(ProjectionDataRegistry projectionDataRegistry)
protected Grid doCreateGrid()
protected ProjectedGrid doCreateProjectedGrid(Grid grid)
protected void handleSatisfyStateData(ContainerCluster cluster, SatisfyStateData satisfyData)
protected void killContainer(org.apache.hadoop.yarn.api.records.Container container)
protected java.util.List<java.lang.String> onContainerLaunchCommands(org.apache.hadoop.yarn.api.records.Container container,
ContainerCluster cluster,
java.util.List<java.lang.String> commands)container - コンテナー cluster - クラスター commands - 元のコマンド protected java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> buildLocalizedResources(ContainerCluster cluster)