public class StaticEventingAppmaster extends AbstractEventingAppmaster implements YarnAppmaster
コンストラクターと説明 |
---|
StaticEventingAppmaster() |
修飾子と型 | メソッドと説明 |
---|---|
protected boolean | isComplete() アプリケーションが完了したと見なされるかどうかを示す状態を返します。 |
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 boolean | onContainerFailed(org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus) 完了したコンテナーが失敗した場合に呼び出されます。 |
protected void | onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container) ContainerLaunchedEvent がアプリケーションイベントとして受信されたときに呼び出されます。 |
void | submitApplication() アプリケーションを送信して実行します。 |
getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, onInit, shutdownContainers
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
afterPropertiesSet, doStart, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAppmasterStateListener, setEnvironment, setParameters
public void submitApplication()
YarnAppmaster
YarnAppmaster
の submitApplication
protected void onContainerAllocated(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmaster
ContainerAllocationEvent
がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container
がメソッドに渡されます。AbstractEventingAppmaster
の onContainerAllocated
container
- コンテナー protected void onContainerLaunched(org.apache.hadoop.yarn.api.records.Container container)
AbstractEventingAppmaster
ContainerLaunchedEvent
がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた Container
がメソッドに渡されます。AbstractEventingAppmaster
の onContainerLaunched
container
- コンテナー protected void onContainerCompleted(org.apache.hadoop.yarn.api.records.ContainerStatus status)
AbstractEventingAppmaster
ContainerCompletedEvent
がアプリケーションイベントとして受信されたときに呼び出されます。ラップされた ContainerStatus
がメソッドに渡されます。AbstractEventingAppmaster
の onContainerCompleted
status
- コンテナーの状態 protected boolean onContainerFailed(org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus)
デフォルトの実装では何も実行されず、失敗したコンテナーが処理されなかったことだけが返されます。
containerStatus
- コンテナーの状態 protected boolean isComplete()
ContainerMonitor.completedCount()
からのカウントによって満たされているかどうかを比較します。