Class ApplicationReport
java.lang.Object
org.apache.hadoop.yarn.api.records.ApplicationReport
ApplicationReport is a report of an application.
It includes details such as:
ApplicationIdof the application.- Applications user.
- Application queue.
- Application name.
- Host on which the
ApplicationMasteris running. - RPC port of the
ApplicationMaster. - Tracking URL.
YarnApplicationStateof the application.- Diagnostic information in case of errors.
- Start time of the application.
- Client
Tokenof the application (if security is enabled).
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionabstract StringGet the default Node Label expression for all the application's containersabstract TokenGet the AMRM token of the application.abstract ApplicationIdGet theApplicationIdof the application.abstract ApplicationResourceUsageReportRetrieve the structure containing the job resources for this applicationGet all tags corresponding to the applicationabstract Map<ApplicationTimeoutType,ApplicationTimeout> abstract StringGet the application's Typeabstract StringGet the default Node Label expression for all the application's containersabstract TokenGet the client token for communicating with theApplicationMaster.abstract ApplicationAttemptIdGet theApplicationAttemptIdof the current attempt of the applicationabstract StringGet the diagnositic information of the application in case of errors.abstract FinalApplicationStatusGet the final finish status of the application.abstract longGet the finish time of the application.abstract StringgetHost()Get the host on which theApplicationMasteris running.abstract longabstract LogAggregationStatusGet log aggregation status for the applicationabstract StringgetName()Get the user-defined name of the application.abstract StringGet the original not-proxied tracking url for the application.abstract PriorityGet priority of the applicationabstract floatGet the application's progress ( range 0.0 to 1.0 )abstract StringgetQueue()Get the queue to which the application was submitted.abstract StringGet RM ClusterId.abstract intGet the RPC port of theApplicationMaster.abstract longGet the start time of the application.abstract longabstract StringGet the tracking url for the application.abstract StringgetUser()Get the user who submitted the application.abstract YarnApplicationStateGet theYarnApplicationStateof the application.abstract booleanstatic ApplicationReportnewInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) static ApplicationReportnewInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) static ApplicationReportnewInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) static ApplicationReportnewInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) static ApplicationReportnewInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) abstract voidsetAmNodeLabelExpression(String amNodeLabelExpression) abstract voidsetAMRMToken(Token amRmToken) abstract voidsetApplicationId(ApplicationId applicationId) abstract voidStore the structure containing the job resources for this applicationabstract voidsetApplicationTags(Set<String> tags) abstract voidabstract voidsetApplicationType(String applicationType) abstract voidsetAppNodeLabelExpression(String appNodeLabelExpression) abstract voidsetClientToAMToken(Token clientToAMToken) abstract voidsetCurrentApplicationAttemptId(ApplicationAttemptId applicationAttemptId) abstract voidsetDiagnostics(String diagnostics) abstract voidsetFinalApplicationStatus(FinalApplicationStatus finishState) abstract voidsetFinishTime(long finishTime) abstract voidabstract voidsetLaunchTime(long setLaunchTime) abstract voidsetLogAggregationStatus(LogAggregationStatus logAggregationStatus) abstract voidabstract voidabstract voidsetPriority(Priority priority) abstract voidsetProgress(float progress) abstract voidabstract voidsetRMClusterId(String rmClusterId) abstract voidsetRpcPort(int rpcPort) abstract voidsetStartTime(long startTime) abstract voidsetSubmitTime(long submitTime) abstract voidsetTrackingUrl(String url) abstract voidsetUnmanagedApp(boolean unmanagedApplication) abstract voidabstract void
-
Constructor Details
-
ApplicationReport
public ApplicationReport()
-
-
Method Details
-
newInstance
@Private @Unstable public static ApplicationReport newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) -
newInstance
@Private @Unstable public static ApplicationReport newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) -
newInstance
@Private @Unstable public static ApplicationReport newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) -
newInstance
@Private @Unstable public static ApplicationReport newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) -
newInstance
@Private @Unstable public static ApplicationReport newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) -
getApplicationId
Get theApplicationIdof the application.- Returns:
ApplicationIdof the application
-
setApplicationId
-
getCurrentApplicationAttemptId
Get theApplicationAttemptIdof the current attempt of the application- Returns:
ApplicationAttemptIdof the attempt
-
setCurrentApplicationAttemptId
@Private @Unstable public abstract void setCurrentApplicationAttemptId(ApplicationAttemptId applicationAttemptId) -
getUser
Get the user who submitted the application.- Returns:
- user who submitted the application
-
setUser
-
getQueue
Get the queue to which the application was submitted.- Returns:
- queue to which the application was submitted
-
setQueue
-
getName
Get the user-defined name of the application.- Returns:
- name of the application
-
setName
-
getHost
Get the host on which theApplicationMasteris running.- Returns:
- host on which the
ApplicationMasteris running
-
setHost
-
getRpcPort
@Public @Stable public abstract int getRpcPort()Get the RPC port of theApplicationMaster.- Returns:
- RPC port of the
ApplicationMaster
-
setRpcPort
@Private @Unstable public abstract void setRpcPort(int rpcPort) -
getClientToAMToken
Get the client token for communicating with theApplicationMaster.ClientToAMToken is the security token used by the AMs to verify authenticity of any
client.The
ResourceManager, provides a secure token (viagetClientToAMToken()) which is verified by the ApplicationMaster when the client directly talks to an AM.- Returns:
- client token for communicating with the
ApplicationMaster
-
setClientToAMToken
-
getYarnApplicationState
Get theYarnApplicationStateof the application.- Returns:
YarnApplicationStateof the application
-
setYarnApplicationState
-
getDiagnostics
Get the diagnositic information of the application in case of errors.- Returns:
- diagnositic information of the application in case of errors
-
setDiagnostics
-
getTrackingUrl
Get the tracking url for the application.- Returns:
- tracking url for the application
-
setTrackingUrl
-
getOriginalTrackingUrl
Get the original not-proxied tracking url for the application. This is intended to only be used by the proxy itself.- Returns:
- the original not-proxied tracking url for the application
-
setOriginalTrackingUrl
-
getStartTime
@Public @Stable public abstract long getStartTime()Get the start time of the application.- Returns:
- start time of the application
-
setStartTime
@Private @Unstable public abstract void setStartTime(long startTime) -
getSubmitTime
@Public @Stable public abstract long getSubmitTime() -
setSubmitTime
@Private @Unstable public abstract void setSubmitTime(long submitTime) -
setLaunchTime
@Private @Unstable public abstract void setLaunchTime(long setLaunchTime) -
getLaunchTime
@Public @Unstable public abstract long getLaunchTime() -
getFinishTime
@Public @Stable public abstract long getFinishTime()Get the finish time of the application.- Returns:
- finish time of the application
-
setFinishTime
@Private @Unstable public abstract void setFinishTime(long finishTime) -
getFinalApplicationStatus
Get the final finish status of the application.- Returns:
- final finish status of the application
-
setFinalApplicationStatus
@Private @Unstable public abstract void setFinalApplicationStatus(FinalApplicationStatus finishState) -
getApplicationResourceUsageReport
Retrieve the structure containing the job resources for this application- Returns:
- the job resources structure for this application
-
setApplicationResourceUsageReport
@Private @Unstable public abstract void setApplicationResourceUsageReport(ApplicationResourceUsageReport appResources) Store the structure containing the job resources for this application- Parameters:
appResources- structure for this application
-
getProgress
@Public @Stable public abstract float getProgress()Get the application's progress ( range 0.0 to 1.0 )- Returns:
- application's progress
-
setProgress
@Private @Unstable public abstract void setProgress(float progress) -
getApplicationType
Get the application's Type- Returns:
- application's Type
-
setApplicationType
-
getApplicationTags
Get all tags corresponding to the application- Returns:
- Application's tags
-
setApplicationTags
-
setAMRMToken
-
getAMRMToken
Get the AMRM token of the application.The AMRM token is required for AM to RM scheduling operations. For managed Application Masters YARN takes care of injecting it. For unmanaged Applications Masters, the token must be obtained via this method and set in the
UserGroupInformationof the current user.The AMRM token will be returned only if all the following conditions are met:
- the requester is the owner of the ApplicationMaster
- the application master is an unmanaged ApplicationMaster
- the application master is in ACCEPTED state
- Returns:
- the AM to RM token if available.
-
getLogAggregationStatus
Get log aggregation status for the application- Returns:
- Application's log aggregation status
-
setLogAggregationStatus
@Private @Unstable public abstract void setLogAggregationStatus(LogAggregationStatus logAggregationStatus) -
isUnmanagedApp
@Public @Unstable public abstract boolean isUnmanagedApp()- Returns:
- true if the AM is not managed by the RM
-
setUnmanagedApp
@Public @Unstable public abstract void setUnmanagedApp(boolean unmanagedApplication) - Parameters:
unmanagedApplication- true if RM should not manage the AM
-
getPriority
Get priority of the application- Returns:
- Application's priority
-
setPriority
-
getAppNodeLabelExpression
Get the default Node Label expression for all the application's containers- Returns:
- Application's NodeLabelExpression
-
setAppNodeLabelExpression
-
getAmNodeLabelExpression
Get the default Node Label expression for all the application's containers- Returns:
- Application's NodeLabelExpression
-
setAmNodeLabelExpression
-
getApplicationTimeouts
@Public @Unstable public abstract Map<ApplicationTimeoutType,ApplicationTimeout> getApplicationTimeouts() -
setApplicationTimeouts
@Private @Unstable public abstract void setApplicationTimeouts(Map<ApplicationTimeoutType, ApplicationTimeout> timeouts) -
getRMClusterId
Get RM ClusterId.- Returns:
- RM ClusterId
-
setRMClusterId
-