|
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.ApplicationMasterProtocol>
org.springframework.yarn.am.AppmasterRmTemplate
public class AppmasterRmTemplate
Template implementation for AppmasterRmOperations wrapping
communication using ApplicationMasterProtocol. Methods for this
template wraps possible exceptions into Spring Dao exception hierarchy.
| Constructor Summary | |
|---|---|
AppmasterRmTemplate(org.apache.hadoop.conf.Configuration config)
Instantiates a new AppmasterRmTemplate. |
|
| Method Summary | |
|---|---|
org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse |
allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request)
Allocate container. |
org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse |
finish(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request)
Finish the application master. |
protected java.net.InetSocketAddress |
getRpcAddress(org.apache.hadoop.conf.Configuration config)
Gets the InetSocketAddress where this accessor should connect. |
org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse |
registerApplicationMaster(java.lang.String host,
java.lang.Integer rpcPort,
java.lang.String trackUrl)
Register application master. |
| Methods inherited from class org.springframework.yarn.rpc.YarnRpcAccessor |
|---|
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy, getUser |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AppmasterRmTemplate(org.apache.hadoop.conf.Configuration config)
config - the hadoop configuration| Method Detail |
|---|
public org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse registerApplicationMaster(java.lang.String host,
java.lang.Integer rpcPort,
java.lang.String trackUrl)
AppmasterRmOperations
registerApplicationMaster in interface AppmasterRmOperationshost - the hostrpcPort - the rpc porttrackUrl - the track url
RegisterApplicationMasterResponsepublic org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocate(org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest request)
AppmasterRmOperations
allocate in interface AppmasterRmOperationsrequest - the request
public org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse finish(org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest request)
AppmasterRmOperations
finish in interface AppmasterRmOperationsrequest - the FinishApplicationMasterRequest
FinishApplicationMasterResponseprotected 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.ApplicationMasterProtocol>config - the yarn configuration
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||