Package | Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords | |
org.apache.hadoop.yarn.api.records | |
org.apache.hadoop.yarn.client.api |
Modifier and Type | Method and Description |
---|---|
abstract ApplicationId |
UseSharedCacheResourceRequest.getAppId()
Get the
ApplicationId of the resource to be used. |
abstract ApplicationId |
ReleaseSharedCacheResourceRequest.getAppId()
Get the
ApplicationId of the resource to be released. |
abstract ApplicationId |
GetApplicationAttemptsRequest.getApplicationId()
Get the
ApplicationId of an application |
abstract ApplicationId |
GetApplicationReportRequest.getApplicationId()
Get the
ApplicationId of the application. |
abstract ApplicationId |
KillApplicationRequest.getApplicationId()
Get the
ApplicationId of the application to be aborted. |
abstract ApplicationId |
MoveApplicationAcrossQueuesRequest.getApplicationId()
Get the
ApplicationId of the application to be moved. |
abstract ApplicationId |
GetNewApplicationResponse.getApplicationId()
Get the new
ApplicationId allocated by the
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
static GetApplicationAttemptsRequest |
GetApplicationAttemptsRequest.newInstance(ApplicationId applicationId) |
static GetApplicationReportRequest |
GetApplicationReportRequest.newInstance(ApplicationId applicationId) |
static KillApplicationRequest |
KillApplicationRequest.newInstance(ApplicationId applicationId) |
static MoveApplicationAcrossQueuesRequest |
MoveApplicationAcrossQueuesRequest.newInstance(ApplicationId appId,
String queue) |
abstract void |
UseSharedCacheResourceRequest.setAppId(ApplicationId id)
Set the
ApplicationId of the resource to be used. |
abstract void |
ReleaseSharedCacheResourceRequest.setAppId(ApplicationId id)
Set the
ApplicationId of the resource to be released. |
abstract void |
GetApplicationAttemptsRequest.setApplicationId(ApplicationId applicationId)
Set the
ApplicationId of an application |
abstract void |
GetApplicationReportRequest.setApplicationId(ApplicationId applicationId)
Set the
ApplicationId of the application |
abstract void |
KillApplicationRequest.setApplicationId(ApplicationId applicationId) |
abstract void |
MoveApplicationAcrossQueuesRequest.setApplicationId(ApplicationId appId)
Set the
ApplicationId of the application to be moved. |
Modifier and Type | Method and Description |
---|---|
abstract ApplicationId |
ApplicationAttemptId.getApplicationId()
Get the
ApplicationId of the ApplicationAttempId . |
abstract ApplicationId |
ApplicationSubmissionContext.getApplicationId()
Get the
ApplicationId of the submitted application. |
abstract ApplicationId |
ApplicationReport.getApplicationId()
Get the
ApplicationId of the application. |
Modifier and Type | Method and Description |
---|---|
int |
ApplicationId.compareTo(ApplicationId other) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
String applicationType,
boolean keepContainers,
String appLabelExpression,
ResourceRequest resourceRequest) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
LogAggregationContext logAggregationContext) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
long attemptFailuresValidityInterval) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType,
boolean keepContainers,
String appLabelExpression,
String amContainerLabelExpression) |
abstract void |
ApplicationSubmissionContext.setApplicationId(ApplicationId applicationId)
Set the
ApplicationId of the submitted application. |
Modifier and Type | Method and Description |
---|---|
abstract ApplicationId |
YarnClient.submitApplication(ApplicationSubmissionContext appContext)
Submit a new application to
YARN. It is a blocking call - it
will not return ApplicationId until the submitted application is
submitted successfully and accepted by the ResourceManager. |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.hadoop.security.token.Token<AMRMTokenIdentifier> |
YarnClient.getAMRMToken(ApplicationId appId)
Get the AMRM token of the application.
|
abstract List<ApplicationAttemptReport> |
AHSClient.getApplicationAttempts(ApplicationId applicationId)
Get a report of all (ApplicationAttempts) of Application in the cluster.
|
abstract List<ApplicationAttemptReport> |
YarnClient.getApplicationAttempts(ApplicationId applicationId)
Get a report of all (ApplicationAttempts) of Application in the cluster.
|
abstract ApplicationReport |
AHSClient.getApplicationReport(ApplicationId appId)
Get a report of the given Application.
|
abstract ApplicationReport |
YarnClient.getApplicationReport(ApplicationId appId)
Get a report of the given Application.
|
abstract void |
YarnClient.killApplication(ApplicationId applicationId)
Kill an application identified by given ID.
|
abstract void |
YarnClient.moveApplicationAcrossQueues(ApplicationId appId,
String queue)
Attempts to move the given application to the given queue.
|
abstract void |
SharedCacheClient.release(ApplicationId applicationId,
String resourceKey)
The method to release a resource with the
SharedCacheManager.
This method is called once an application is no longer using a claimed
resource in the shared cache. |
abstract Path |
SharedCacheClient.use(ApplicationId applicationId,
String resourceKey)
The method to claim a resource with the
SharedCacheManager.
The client uses a checksum to identify the resource and an
ApplicationId to identify which application will be using the
resource. |
Copyright © 2017 Apache Software Foundation. All rights reserved.