public abstract class AbstractProcessingAppmaster extends AbstractServicesAppmaster implements ContainerLauncherInterceptor
アプリケーションマスターが実行できることに関して、実際の実装は非常に静的であると言えます。ライフサイクルを開始する前に、すべてを把握しておく必要があります。実装では、アプリケーションに参加するコンテナーの数、それらのコンテナーが実行する内容、コンテナー実行から期待される結果が何であるかを把握しておく必要があります。
| コンストラクターと説明 |
|---|
AbstractProcessingAppmaster() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected void | onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container) コンテナーが割り当てられた時に呼び出されます。 |
protected void | onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status) コンテナーが完了したときに呼び出されます。 |
protected void | onInit() この init メソッド中に、グローバルアプリケーションマスターインスタンス固有の ApplicationAttemptId が構築されます。 |
org.apache.hadoop.yarn.api.records.ContainerLaunchContext | preLaunch(org.apache.hadoop.yarn.api.records.Container container, org.apache.hadoop.yarn.api.records.ContainerLaunchContext context)ContainerLaunchContext を使用してコンテナーを起動する前に呼び出されます。 |
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, setTemplate, shutdownContainersafterPropertiesSet, 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 org.apache.hadoop.yarn.api.records.ContainerLaunchContext preLaunch(org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext context)ContainerLauncherInterceptorContainerLaunchContext を使用してコンテナーを起動する前に呼び出されます。ContainerLauncherInterceptor の preLaunch container - Containercontext - ContainerLaunchContextContainerLaunchContextprotected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
container - コンテナー protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
status - ステータス