メソッドの詳細

• getInstance

  public static YarnClusterManager getInstance()

  YarnClusterManager のシングルトンインスタンスを取得します。

  戻り値:

  シングルトンインスタンス

• getInstance

  public static YarnClusterManager getInstance(boolean registerShutdownHook)

  YarnClusterManager のシングルトンインスタンスを取得します。

  パラメーター:

  registerShutdownHook - 真の場合、シャットダウンフックを登録する

  戻り値:

  シングルトンインスタンス

• getCluster

  public YarnCluster getCluster(ClusterInfo clusterInfo)

  ミニクラスターを取得して起動します。

  パラメーター:

  clusterInfo - クラスターに関する情報

  戻り値:

  実行中のミニクラスター

• closeCluster

  public boolean closeCluster(YarnCluster cluster)

  YarnCluster を閉じてマネージャーキャッシュから削除します。

  パラメーター:

  cluster - Yarn クラスター

  戻り値:

  クラスターが閉じられた場合は true、それ以外の場合は false

• close

  public void close()

  マネージャーを閉じ、シャットダウンフックを削除し、実行中のすべてのクラスターを閉じます。

• registerShutdownHook

  public void registerShutdownHook()

  まだ実行されていない場合に、マネージャーがクラスターを正常にシャットダウンできるように、JVM シャットダウンフックを登録します。これは通常、テストのシナリオです。

• doClose

  protected void doClose()

  実行中のすべてのクラスターを停止し、登録を解除します。