|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.rpc.YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol>
org.springframework.yarn.am.AppmasterCmTemplate
public class AppmasterCmTemplate
Template implementation for AppmasterCmOperations wrapping
communication using ContainerManagementProtocol. Methods for this
template wraps possible exceptions into Spring Dao exception hierarchy.
| Constructor Summary | |
|---|---|
AppmasterCmTemplate(org.apache.hadoop.conf.Configuration config,
org.apache.hadoop.yarn.api.records.Container container)
Instantiates a new AppmasterCmTemplate. |
|
| Method Summary | |
|---|---|
org.apache.hadoop.yarn.api.records.ContainerStatus |
getContainerStatus()
Gets the container status. |
protected java.net.InetSocketAddress |
getRpcAddress(org.apache.hadoop.conf.Configuration config)
Gets the InetSocketAddress where this accessor should connect. |
protected org.apache.hadoop.security.UserGroupInformation |
getUser()
Gets the user used to
create the proxy. |
org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse |
startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest request)
Start container. |
org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse |
stopContainers()
Stop container. |
| Methods inherited from class org.springframework.yarn.rpc.YarnRpcAccessor |
|---|
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AppmasterCmTemplate(org.apache.hadoop.conf.Configuration config,
org.apache.hadoop.yarn.api.records.Container container)
config - the hadoop configationcontainer - the Container| Method Detail |
|---|
public org.apache.hadoop.yarn.api.protocolrecords.StartContainersResponse startContainers(org.apache.hadoop.yarn.api.protocolrecords.StartContainersRequest request)
AppmasterCmOperations
startContainers in interface AppmasterCmOperationsrequest - the request
public org.apache.hadoop.yarn.api.protocolrecords.StopContainersResponse stopContainers()
AppmasterCmOperations
stopContainers in interface AppmasterCmOperationspublic org.apache.hadoop.yarn.api.records.ContainerStatus getContainerStatus()
AppmasterCmOperations
getContainerStatus in interface AppmasterCmOperationsprotected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessorInetSocketAddress where this accessor should connect.
getRpcAddress in class YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol>config - the yarn configuration
protected org.apache.hadoop.security.UserGroupInformation getUser()
YarnRpcAccessoruser used to
create the proxy. Default implementation delegates into
UserGroupInformation.getCurrentUser().
getUser in class YarnRpcAccessor<org.apache.hadoop.yarn.api.ContainerManagementProtocol>YarnRpcAccessor.createProxy()
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||