public abstract class AbstractEventingAppmaster extends AbstractServicesAppmaster implements org.springframework.context.ApplicationListener<AbstractYarnEvent>
このインスタンスのライフサイクルは、アプリケーションマスターの起動前に存在していた情報や状態に縛られません。コンテナーはオンデマンドでリクエストおよび起動でき、アプリケーションマスターはいつアプリケーションを終了すべきかを判断する責任があります。
イベント通信の複雑なニーズのため、実際のイベントシステムは、さまざまなユースケースのニーズに合わせてさまざまなシステムを接続できるように抽象化されています。
| コンストラクターと説明 |
|---|
AbstractEventingAppmaster() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected java.util.Map<org.apache.hadoop.yarn.api.records.Container,ContainerRegisterInfo> | getRegisteredContainers() |
void | onApplicationEvent(AbstractYarnEvent event) |
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 void | onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)ContainerLaunchedEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
protected void | onContainerLaunchRequestFailed(org.apache.hadoop.yarn.api.records.Container container)ContainerLaunchRequestFailedEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
protected void | onInit() この init メソッド中に、グローバルアプリケーションマスターインスタンス固有の ApplicationAttemptId が構築されます。 |
protected boolean | shutdownContainers() コンテナーをシャットダウンします。 |
getAllocator, 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 java.lang.ExceptionAbstractAppmasterApplicationAttemptId が構築されます。AbstractAppmaster の onInit java.lang.Exception - 例外 LifecycleObjectSupport.onInit()public void onApplicationEvent(AbstractYarnEvent event)
org.springframework.context.ApplicationListener<AbstractYarnEvent> の onApplicationEvent protected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
ContainerAllocationEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container がメソッドに渡されます。container - コンテナー protected void onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)
ContainerLaunchedEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container がメソッドに渡されます。container - コンテナー protected void onContainerLaunchRequestFailed(org.apache.hadoop.yarn.api.records.Container container)
ContainerLaunchRequestFailedEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container がメソッドに渡されます。container - コンテナー protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
ContainerCompletedEvent がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた ContainerStatus がメソッドに渡されます。status - コンテナーの状態 protected boolean shutdownContainers()
AbstractAppmasterAbstractAppmaster の shutdownContainers protected java.util.Map<org.apache.hadoop.yarn.api.records.Container,ContainerRegisterInfo> getRegisteredContainers()