public class ClientRmTemplate extends YarnRpcAccessor<ApplicationClientProtocol> implements ClientRmOperations
ClientRmOperations wrapping
communication using ApplicationClientProtocol. Methods for this
template wraps possible exceptions into Spring Dao exception hierarchy.| Constructor and Description |
|---|
ClientRmTemplate(Configuration config)
Constructs a
ClientRmTemplate with a given yarn configuration. |
| Modifier and Type | Method and Description |
|---|---|
ApplicationReport |
getApplicationReport(ApplicationId applicationId)
Gets a report of the application.
|
Token |
getDelegationToken(java.lang.String renewer)
Gets the resource manager delegation token.
|
GetNewApplicationResponse |
getNewApplication()
Requests a new application from a resource manager.
|
protected java.net.InetSocketAddress |
getRpcAddress(Configuration config)
Gets the
InetSocketAddress where this accessor should connect. |
KillApplicationResponse |
killApplication(ApplicationId applicationId)
Requests
ResourceManager to abort submitted application. |
java.util.List<ApplicationReport> |
listApplications()
Gets a list of
ApplicationReports from a resource manager. |
java.util.List<ApplicationReport> |
listApplications(java.util.EnumSet<YarnApplicationState> states,
java.util.Set<java.lang.String> types)
Gets a list of
ApplicationReports from a resource manager. |
SubmitApplicationResponse |
submitApplication(ApplicationSubmissionContext appSubContext)
Submits a new application into resource manager.
|
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy, getUserpublic ClientRmTemplate(Configuration config)
ClientRmTemplate with a given yarn configuration.config - the yarn configurationpublic java.util.List<ApplicationReport> listApplications(java.util.EnumSet<YarnApplicationState> states, java.util.Set<java.lang.String> types)
ClientRmOperationsApplicationReports from a resource manager. Allows
to filter results by using a set of YarnApplicationStates and
registered application types.listApplications in interface ClientRmOperationsstates - the yarn application statestypes - the yarn application typesApplicationReportspublic java.util.List<ApplicationReport> listApplications()
ClientRmOperationsApplicationReports from a resource manager.listApplications in interface ClientRmOperationsApplicationReportspublic GetNewApplicationResponse getNewApplication()
ClientRmOperationsApplicationId but response
also contains information about resource capabilities.getNewApplication in interface ClientRmOperationsGetNewApplicationResponsepublic SubmitApplicationResponse submitApplication(ApplicationSubmissionContext appSubContext)
ClientRmOperationssubmitApplication in interface ClientRmOperationsappSubContext - the Application Submission ContextSubmitApplicationResponsepublic KillApplicationResponse killApplication(ApplicationId applicationId)
ClientRmOperationsResourceManager to abort submitted application.killApplication in interface ClientRmOperationsapplicationId - the application idKillApplicationResponsepublic Token getDelegationToken(java.lang.String renewer)
ClientRmOperationsgetDelegationToken in interface ClientRmOperationsrenewer - the renewer as kerberos principalpublic ApplicationReport getApplicationReport(ApplicationId applicationId)
ClientRmOperationsgetApplicationReport in interface ClientRmOperationsapplicationId - the application idApplicationReportprotected java.net.InetSocketAddress getRpcAddress(Configuration config)
YarnRpcAccessorInetSocketAddress where this accessor should connect.getRpcAddress in class YarnRpcAccessor<ApplicationClientProtocol>config - the yarn configuration