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, setMonitor
addAppmasterStateListener, 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, shutdownContainers
afterPropertiesSet, doStart, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
protected void onInit() throws java.lang.Exception
AbstractAppmaster
ApplicationAttemptId
が構築されます。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)
ContainerLauncherInterceptor
ContainerLaunchContext
を使用してコンテナーを起動する前に呼び出されます。ContainerLauncherInterceptor
の preLaunch
container
- Container
context
- ContainerLaunchContext
ContainerLaunchContext
protected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
container
- コンテナー protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
status
- ステータス