public class AppmasterRmTemplate extends YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationMasterProtocol> implements AppmasterRmOperations
ApplicationMasterProtocol を使用して通信をラップする AppmasterRmOperations のテンプレートの実装。このテンプレートのメソッドは、起こりうる例外を Spring Dao 例外階層にラップします。| コンストラクターと説明 |
|---|
AppmasterRmTemplate(org.apache.hadoop.conf.Configuration config) 新しい AppmasterRmTemplate をインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse | allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request) コンテナーを割り当てます。 |
org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse | finish(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request) アプリケーションマスターを終了します。 |
protected java.net.InetSocketAddress | getRpcAddress(org.apache.hadoop.conf.Configuration config) このアクセサーが接続する InetSocketAddress を取得します。 |
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse | registerApplicationMaster(java.lang.String host, java.lang.Integer rpcPort, java.lang.String trackUrl) アプリケーションマスターを登録します。 |
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy, getUserpublic AppmasterRmTemplate(org.apache.hadoop.conf.Configuration config)
config - Hadoop の設定 public org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerApplicationMaster(java.lang.String host,
java.lang.Integer rpcPort,
java.lang.String trackUrl)AppmasterRmOperationsAppmasterRmOperations 内の registerApplicationMaster host - ザホスト rpcPort - RPC ポート trackUrl - トラックの URLRegisterApplicationMasterResponsepublic org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request)
AppmasterRmOperationsAppmasterRmOperations 内の allocate request - リクエスト public org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finish(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request)
AppmasterRmOperationsAppmasterRmOperations 内の finish request - FinishApplicationMasterRequestFinishApplicationMasterResponseprotected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessorInetSocketAddress を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationMasterProtocol> の getRpcAddress config - 糸の構成