フィールドの詳細

• applicationContext

  protected org.springframework.context.ApplicationContext applicationContext

• configuration

  protected org.apache.hadoop.conf.Configuration configuration

• yarnCluster

  protected YarnCluster yarnCluster

• yarnClient

  protected YarnClient yarnClient

コンストラクターの詳細

• AbstractYarnClusterTests

  public AbstractYarnClusterTests()

メソッドの詳細

• getApplicationContext

  public org.springframework.context.ApplicationContext getApplicationContext()

  テスト用の ApplicationContext を取得します。

  戻り値:

  アプリケーションコンテキスト

• setApplicationContext

  public final void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

  次で指定:

  インターフェース org.springframework.context.ApplicationContextAware の setApplicationContext 

• getConfiguration

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

  テスト用に実行中のクラスターランタイム Configuration を取得します。

  戻り値:

  Yarn クラスタ構成

• setConfiguration

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

  Configuration を設定します。

  パラメーター:

  configuration - 構成

• getYarnCluster

  public YarnCluster getYarnCluster()

  テスト用に実行中の YarnCluster を取得します。

  戻り値:

  Yarn クラスター

• setYarnCluster

  @Autowired
  public void setYarnCluster(YarnCluster yarnCluster)

  YarnCluster を設定します

  パラメーター:

  yarnCluster - Yarn クラスター

• getYarnClient

  public YarnClient getYarnClient()

  YarnClient を取得します。

  戻り値:

  Yarn クライアント

• setYarnClient

  @Autowired
  public void setYarnClient(YarnClient yarnClient)

  YarnClient を設定します。

  パラメーター:

  yarnClient - Yarn クライアント

• submitApplicationAndWait

  protected ApplicationInfo submitApplicationAndWait()
                                              throws java.lang.Exception

  アプリケーションを送信し、状態を待機します。デフォルトでは 60 秒間待機します。

  戻り値:

  申請情報を送信

  例外:

  java.lang.Exception - 例外が発生した場合

  関連事項:

  ApplicationInfo, submitApplicationAndWaitState(long, TimeUnit, YarnApplicationState...)

• submitApplicationAndWait

  protected ApplicationInfo submitApplicationAndWait(long timeout,
                                         java.util.concurrent.TimeUnit unit)
                                              throws java.lang.Exception

  アプリケーションを送信し、待機状態になります。

  パラメーター:

  timeout - 待機のタイムアウト

  unit - タイムアウトの単位

  戻り値:

  申請情報を送信

  例外:

  java.lang.Exception - 例外が発生した場合

  関連事項:

  ApplicationInfo, submitApplicationAndWaitState(long, TimeUnit, YarnApplicationState...)

• submitApplicationAndWaitState

  protected ApplicationInfo submitApplicationAndWaitState(long timeout,
                                              java.util.concurrent.TimeUnit unit,
                                              org.apache.hadoop.yarn.api.records.YarnApplicationState... applicationStates)
                                                   throws java.lang.Exception

  アプリケーションと待機状態を送信します。何かが失敗した場合、または待機 / ポーリング操作後の最終的な既知の状態の場合、返される状態は NULL です。アプリケーション状態の配列を使用すると、状態が一致した場合に待機ループからすぐに戻ることができます。

  パラメーター:

  timeout - 待機のタイムアウト

  unit - タイムアウトの単位

  applicationStates - アプリケーションは待機するように指示する

  戻り値:

  申請情報を送信

  例外:

  java.lang.Exception - 例外が発生した場合

  関連事項:

  ApplicationInfo

• submitApplication

  protected org.apache.hadoop.yarn.api.records.ApplicationId submitApplication()

  申請書を提出。

  戻り値:

  提出された申請書 ApplicationId

• waitState

  protected org.apache.hadoop.yarn.api.records.YarnApplicationState waitState(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
                                                                  long timeout,
                                                                  java.util.concurrent.TimeUnit unit,
                                                                  org.apache.hadoop.yarn.api.records.YarnApplicationState... applicationStates)
                                                                       throws java.lang.Exception

  待機状態。何かが失敗した場合、または待機 / ポーリング操作後の最終的な既知の状態の場合、返される状態は NULL です。アプリケーション状態の配列を使用すると、状態が一致した場合に待機ループからすぐに戻ることができます。

  パラメーター:

  applicationId - アプリケーション ID

  timeout - 待機のタイムアウト

  unit - タイムアウトの単位

  applicationStates - アプリケーションは待機するように指示する

  戻り値:

  最後に認識されたアプリケーション状態、またはタイムアウトの場合は NULL 

  例外:

  java.lang.Exception - 例外が発生した場合

• killApplication

  protected void killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

  アプリケーションを終了します。

  パラメーター:

  applicationId - アプリケーション ID

• getState

  protected org.apache.hadoop.yarn.api.records.YarnApplicationState getState(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

  現在のアプリケーションの状態を取得します。

  パラメーター:

  applicationId - Yarn アプリアプリケーション ID

  戻り値:

  現在のアプリケーションの状態、または見つからない場合は NULL