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, getProxypublic AppmasterCmTemplate(org.apache.hadoop.conf.Configuration config,
org.apache.hadoop.yarn.api.records.Container container)config - Hadoop の設定 container - Containerpublic org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest request)
AppmasterCmOperationsAppmasterCmOperations 内の startContainers request - リクエスト public org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse stopContainers()
AppmasterCmOperationsAppmasterCmOperations 内の stopContainers public org.apache.hadoop.yarn.api.records.ContainerStatus getContainerStatus()
AppmasterCmOperationsAppmasterCmOperations 内の getContainerStatus protected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessorInetSocketAddress を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol> の getRpcAddress config - 糸の構成 protected org.apache.hadoop.security.UserGroupInformation getUser()
YarnRpcAccessoruser を取得します。デフォルトの実装は UserGroupInformation.getCurrentUser() に委譲されます。YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol> の getUser YarnRpcAccessor.createProxy()