public abstract class AbstractBatchAppmaster extends AbstractEventingAppmaster implements BatchYarnAppmaster, ContainerLauncherInterceptor
| コンストラクターと説明 |
|---|
AbstractBatchAppmaster() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener) パーティション化されたステップ実行状態リスナーを追加します。 |
void | addStepSplits(org.springframework.batch.core.StepExecution masterStepExecution, java.lang.String remoteStepName, java.util.Set<org.springframework.batch.core.StepExecution> stepExecutions, java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests) ステップ分割を追加します。 |
java.util.List<org.springframework.batch.core.StepExecution> | getStepExecutions() ステップ実行を取得します。 |
YarnJobLauncher | getYarnJobLauncher() |
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 | 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 を使用してコンテナーを起動する前に呼び出されます。 |
void | setYarnJobLauncher(YarnJobLauncher yarnJobLauncher) |
getRegisteredContainers, onApplicationEvent, onContainerLaunchRequestFailed, shutdownContainersgetAllocator, 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, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddAppmasterStateListener, setEnvironment, setParameters, submitApplicationprotected void onInit()
throws java.lang.ExceptionAbstractAppmasterApplicationAttemptId が構築されます。AbstractEventingAppmaster の onInit java.lang.Exception - 例外 LifecycleObjectSupport.onInit()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 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 - ContainerLaunchContextContainerLaunchContext@Autowired(required=false) public void setYarnJobLauncher(YarnJobLauncher yarnJobLauncher)
public YarnJobLauncher getYarnJobLauncher()
public void addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener listener)
BatchYarnAppmaster 内の addPartitionedStepExecutionStateListener listener - リスナー public java.util.List<org.springframework.batch.core.StepExecution> getStepExecutions()
BatchYarnAppmaster 内の getStepExecutions public void addStepSplits(org.springframework.batch.core.StepExecution masterStepExecution,
java.lang.String remoteStepName,
java.util.Set<org.springframework.batch.core.StepExecution> stepExecutions,
java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests)BatchYarnAppmaster 内の addStepSplits masterStepExecution - 分割されたステップの親ステップの実行 remoteStepName - リモートステップ名 stepExecutions - ステップ実行の分割 resourceRequests - ステップ実行のリクエストデータ