コンストラクターの詳細

• AbstractAppmaster

  public AbstractAppmaster()

メソッドの詳細

• onInit

  protected void onInit()
                 throws java.lang.Exception

  この init メソッド中に、グローバルアプリケーションマスターインスタンス固有の ApplicationAttemptId が構築されます。

  オーバーライド:

  クラス LifecycleObjectSupport の onInit 

  例外:

  java.lang.Exception - 例外

  関連事項:

  LifecycleObjectSupport.onInit()

• doStop

  protected void doStop()

  クラスからコピーされた説明: LifecycleObjectSupport
  サブクラスは、停止動作でこのメソッドを実装できます。このメソッドは、LifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。

  オーバーライド:

  クラス LifecycleObjectSupport の doStop 

• getTemplate

  public AppmasterRmOperations getTemplate()

  AppmasterRmOperations テンプレートを取得します。

  戻り値:

  AppmasterRmOperations テンプレート

• setTemplate

  public void setTemplate(AppmasterRmOperations template)

  AppmasterRmOperations テンプレートを設定します。

  パラメーター:

  template - 新しい AppmasterRmOperations テンプレート

• getEnvironment

  public java.util.Map<java.lang.String,java.lang.String> getEnvironment()

  環境変数を取得します。

  戻り値:

  環境変数

• getEnvironment

  public java.util.Map<java.lang.String,java.lang.String> getEnvironment(java.lang.String id)

• setEnvironment

  public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)

  環境変数を設定します。

  パラメーター:

  environment - 環境変数

• setEnvironment

  public void setEnvironment(java.lang.String id,
                    java.util.Map<java.lang.String,java.lang.String> environment)

• getParameters

  public java.util.Properties getParameters()

  パラメーターを取得します。

  戻り値:

  パラメーター

• setParameters

  public void setParameters(java.util.Properties parameters)

  パラメーターを設定します。

  パラメーター:

  parameters - 新しいパラメーター

• getConfiguration

  public org.apache.hadoop.conf.Configuration getConfiguration()

  Yarn 構成を取得します。

  戻り値:

  Yarn 構成

• setConfiguration

  public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)

  Yarn 構成を設定します。

  パラメーター:

  configuration - 新しい Yarn 構成

• getCommands

  public java.util.List<java.lang.String> getCommands()

  コマンドを取得します。

  戻り値:

  コマンド

• getCommands

  public java.util.List<java.lang.String> getCommands(java.lang.String id)

  コマンドを取得します。

  パラメーター:

  id - コマンド識別子

  戻り値:

  コマンド

• setCommands

  public void setCommands(java.util.List<java.lang.String> commands)

  コマンドを設定します。

  パラメーター:

  commands - 新しいコマンド

• setCommands

  public void setCommands(java.lang.String id,
                 java.util.List<java.lang.String> commands)

  識別子を使用してコマンドを設定します。

  パラメーター:

  id - コマンド識別子

  commands - 新しいコマンド

• setCommands

  public void setCommands(java.lang.String[] commands)

  コマンドを設定します。

  パラメーター:

  commands - 新しいコマンド

• setCommands

  public void setCommands(java.lang.String id,
                 java.lang.String[] commands)

  識別子を使用してコマンドを設定します。

  パラメーター:

  id - コマンド識別子

  commands - 新しいコマンド

• getApplicationAttemptId

  protected org.apache.hadoop.yarn.api.records.ApplicationAttemptId getApplicationAttemptId()

  アプリケーションの試行 ID を取得します。

  戻り値:

  アプリケーション試行 ID

• setResourceLocalizer

  public void setResourceLocalizer(ResourceLocalizer resourceLocalizer)

  リソースローカライザーを設定します。

  パラメーター:

  resourceLocalizer - 新しいリソースローカライザー

• getResourceLocalizer

  public ResourceLocalizer getResourceLocalizer()

  リソースローカライザーを取得します。

  戻り値:

  リソースローカライザー

• addAppmasterStateListener

  public void addAppmasterStateListener(AppmasterStateListener listener)

  appmaster 状態リスナーを追加します。

  パラメーター:

  listener - リスナー

• getContainerAssign

  public ContainerAssign<java.lang.Object> getContainerAssign()

  コンテナーの割り当てを取得します。

  戻り値:

  コンテナーの割り当て

• setContainerAssign

  public void setContainerAssign(ContainerAssign<java.lang.Object> containerAssign)

  コンテナーの割り当てを設定します。

  パラメーター:

  containerAssign - 新しいコンテナーの割り当て

• setFinalApplicationStatus

  protected void setFinalApplicationStatus(org.apache.hadoop.yarn.api.records.FinalApplicationStatus finalApplicationStatus)

  最終的なアプリケーションステータスを設定します。

  パラメーター:

  finalApplicationStatus - 新しい最終申請ステータス

• notifyCompleted

  protected void notifyCompleted()

  完了した状態を appmaster 状態リスナーに通知します。

• getAppmasterService

  protected AppmasterService getAppmasterService()

  このインスタンスに設定された AppmasterService を取得します。

  戻り値:

  AppmasterService のインスタンス

• getAppmasterClientService

  protected AppmasterService getAppmasterClientService()

  このインスタンスに設定されたクライアント側の AppmasterService を取得します。

  戻り値:

  AppmasterService のインスタンス

• getContainerShutdown

  protected ContainerShutdown getContainerShutdown()

  このインスタンスに設定された ContainerShutdown を取得します。

  戻り値:

  ContainerShutdown のインスタンス

• getAppmasterTrackService

  protected AppmasterTrackService getAppmasterTrackService()

  このインスタンスに設定された AppmasterTrackService を取得します。

  戻り値:

  AppmasterTrackService のインスタンス

• registerAppmaster

  protected org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerAppmaster()

  アプリマスターを登録します。

  戻り値:

  登録申請マスターレスポンス

• finishAppmaster

  protected org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finishAppmaster()

  リソースマネージャーにリクエストを送信して、appmaster を終了します。デフォルトのアプリケーションステータスは FinalApplicationStatus.SUCCEEDED ですが、メソッド setFinalApplicationStatus(FinalApplicationStatus) を使用して変更できます。

  戻り値:

  終了アプリケーションマスターレスポンス

• getCmTemplate

  protected AppmasterCmOperations getCmTemplate(org.apache.hadoop.yarn.api.records.Container container)

  AppmasterCmOperations テンプレートを作成します。

  パラメーター:

  container - コンテナー

  戻り値:

  コンテナーマネージャー操作テンプレート

• shutdownContainers

  protected boolean shutdownContainers()

  コンテナーをシャットダウンします。このメソッドは、appmaster がリソースマネージャーに終了リクエストを送信する前に自動的に呼び出されます。サブクラスはシャットダウンアクションを実行する必要があります。このデフォルトの実装は何も行いません。

  戻り値:

  コンテナーのシャットダウンが成功したとみなされる場合は true