public class AppmasterCmTemplate extends YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol> implements AppmasterCmOperations
ContainerManagementProtocol
を使用して通信をラップする AppmasterCmOperations
のテンプレートの実装。このテンプレートのメソッドは、起こりうる例外を Spring Dao 例外階層にラップします。コンストラクターと説明 |
---|
AppmasterCmTemplate(org.apache.hadoop.conf.Configuration config, org.apache.hadoop.yarn.api.records.Container container) 新しい AppmasterCmTemplate をインスタンス化します。 |
修飾子と型 | メソッドと説明 |
---|---|
org.apache.hadoop.yarn.api.records.ContainerStatus | getContainerStatus() コンテナーのステータスを取得します。 |
protected java.net.InetSocketAddress | getRpcAddress(org.apache.hadoop.conf.Configuration config) このアクセサーが接続する InetSocketAddress を取得します。 |
protected org.apache.hadoop.security.UserGroupInformation | getUser() プロキシの作成に使用される user を取得します。 |
org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse | startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest request) コンテナーの開始。 |
org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse | stopContainers() コンテナーの停止。 |
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy
public AppmasterCmTemplate(org.apache.hadoop.conf.Configuration config, org.apache.hadoop.yarn.api.records.Container container)
config
- Hadoop の設定 container
- Container
public org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest request)
AppmasterCmOperations
AppmasterCmOperations
の startContainers
request
- リクエスト public org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse stopContainers()
AppmasterCmOperations
AppmasterCmOperations
の stopContainers
public org.apache.hadoop.yarn.api.records.ContainerStatus getContainerStatus()
AppmasterCmOperations
AppmasterCmOperations
の getContainerStatus
protected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessor
InetSocketAddress
を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol>
の getRpcAddress
config
- 糸の構成 protected org.apache.hadoop.security.UserGroupInformation getUser()
YarnRpcAccessor
user
を取得します。デフォルトの実装は UserGroupInformation.getCurrentUser()
に委譲されます。YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol>
の getUser
YarnRpcAccessor.createProxy()