public class AppmasterCmTemplate extends YarnRpcAccessor<ContainerManagementProtocol> implements AppmasterCmOperations
AppmasterCmOperations wrapping
communication using ContainerManagementProtocol. Methods for this
template wraps possible exceptions into Spring Dao exception hierarchy.| Constructor and Description |
|---|
AppmasterCmTemplate(Configuration config,
Container container)
Instantiates a new AppmasterCmTemplate.
|
| Modifier and Type | Method and Description |
|---|---|
ContainerStatus |
getContainerStatus()
Gets the container status.
|
protected java.net.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.
|
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxypublic AppmasterCmTemplate(Configuration config, Container container)
config - the hadoop configationcontainer - the Containerpublic StartContainersResponse startContainers(StartContainersRequest request)
AppmasterCmOperationsstartContainers in interface AppmasterCmOperationsrequest - the requestpublic StopContainersResponse stopContainers()
AppmasterCmOperationsstopContainers in interface AppmasterCmOperationspublic ContainerStatus getContainerStatus()
AppmasterCmOperationsgetContainerStatus in interface AppmasterCmOperationsprotected java.net.InetSocketAddress getRpcAddress(Configuration config)
YarnRpcAccessorInetSocketAddress where this accessor should connect.getRpcAddress in class YarnRpcAccessor<ContainerManagementProtocol>config - the yarn configurationprotected UserGroupInformation getUser()
YarnRpcAccessoruser used to
create the proxy. Default implementation delegates into
UserGroupInformation.getCurrentUser().getUser in class YarnRpcAccessor<ContainerManagementProtocol>YarnRpcAccessor.createProxy()