|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.rpc.YarnRpcAccessor<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(Configuration config,
Container container)
Instantiates a new AppmasterCmTemplate. |
|
| Method Summary | |
|---|---|
ContainerStatus |
getContainerStatus()
Gets the container status. |
protected InetSocketAddress |
getRpcAddress(Configuration config)
Gets the InetSocketAddress where this accessor should connect. |
protected UserGroupInformation |
getUser()
Gets the user used to
create the proxy. |
StartContainersResponse |
startContainers(StartContainersRequest request)
Start container. |
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(Configuration config,
Container container)
config - the hadoop configationcontainer - the Container| Method Detail |
|---|
public StartContainersResponse startContainers(StartContainersRequest request)
AppmasterCmOperations
startContainers in interface AppmasterCmOperationsrequest - the request
public StopContainersResponse stopContainers()
AppmasterCmOperations
stopContainers in interface AppmasterCmOperationspublic ContainerStatus getContainerStatus()
AppmasterCmOperations
getContainerStatus in interface AppmasterCmOperationsprotected InetSocketAddress getRpcAddress(Configuration config)
YarnRpcAccessorInetSocketAddress where this accessor should connect.
getRpcAddress in class YarnRpcAccessor<ContainerManagementProtocol>config - the yarn configuration
protected UserGroupInformation getUser()
YarnRpcAccessoruser used to
create the proxy. Default implementation delegates into
UserGroupInformation.getCurrentUser().
getUser in class YarnRpcAccessor<ContainerManagementProtocol>YarnRpcAccessor.createProxy()
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||