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, getUser
public 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)
AppmasterRmOperations
AppmasterRmOperations
の registerApplicationMaster
host
- ザホスト rpcPort
- RPC ポート trackUrl
- トラックの URLRegisterApplicationMasterResponse
public org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request)
AppmasterRmOperations
AppmasterRmOperations
の allocate
request
- リクエスト public org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finish(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request)
AppmasterRmOperations
AppmasterRmOperations
の finish
request
- FinishApplicationMasterRequest
FinishApplicationMasterResponse
protected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessor
InetSocketAddress
を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationMasterProtocol>
の getRpcAddress
config
- 糸の構成