public class RMAppAttemptImpl extends Object implements RMAppAttempt, Recoverable
Modifier and Type | Field and Description |
---|---|
static Priority |
AM_CONTAINER_PRIORITY |
Constructor and Description |
---|
RMAppAttemptImpl(ApplicationAttemptId appAttemptId,
RMContext rmContext,
YarnScheduler scheduler,
ApplicationMasterService masterService,
ApplicationSubmissionContext submissionContext,
Configuration conf,
String user) |
Modifier and Type | Method and Description |
---|---|
Token<ClientToAMTokenIdentifier> |
createClientToken(String client)
Create a token for authenticating a client connection to the app attempt
|
Token<AMRMTokenIdentifier> |
getAMRMToken()
The AMRMToken belonging to this app attempt
|
ApplicationAttemptId |
getAppAttemptId()
Get the application attempt id for this
RMAppAttempt . |
RMAppAttemptState |
getAppAttemptState()
The state of the
RMAppAttempt . |
ApplicationResourceUsageReport |
getApplicationResourceUsageReport()
Get application container and resource usage information.
|
SecretKey |
getClientTokenMasterKey()
The master key for client-to-AM tokens for this app attempt.
|
String |
getDiagnostics()
Diagnostics information for the application attempt.
|
FinalApplicationStatus |
getFinalApplicationStatus()
The final status set by the AM.
|
String |
getHost()
The host on which the
RMAppAttempt is running/ran on. |
List<ContainerStatus> |
getJustFinishedContainers()
Return the list of last set of finished containers.
|
Container |
getMasterContainer()
The container on which the Application Master is running.
|
String |
getOriginalTrackingUrl()
The original url at which the status of the application attempt can be
accessed.
|
float |
getProgress()
Progress for the application attempt.
|
Set<NodeId> |
getRanNodes()
Nodes on which the containers for this
RMAppAttempt ran. |
int |
getRpcPort()
The rpc port of the
RMAppAttempt . |
long |
getStartTime()
the start time of the application.
|
ApplicationSubmissionContext |
getSubmissionContext()
The application submission context for this
RMAppAttempt . |
String |
getTrackingUrl()
The url at which the status of the application attempt can be accessed.
|
String |
getWebProxyBase()
The base to be prepended to web URLs that are not relative, and the user
has been checked.
|
void |
handle(RMAppAttemptEvent event) |
List<ContainerStatus> |
pullJustFinishedContainers()
Return a list of the last set of finished containers, resetting the
finished containers to empty.
|
void |
recover(RMStateStore.RMState state) |
void |
setDiagnostics(String message) |
public static final Priority AM_CONTAINER_PRIORITY
public RMAppAttemptImpl(ApplicationAttemptId appAttemptId, RMContext rmContext, YarnScheduler scheduler, ApplicationMasterService masterService, ApplicationSubmissionContext submissionContext, Configuration conf, String user)
public ApplicationAttemptId getAppAttemptId()
RMAppAttempt
RMAppAttempt
.getAppAttemptId
in interface RMAppAttempt
ApplicationAttemptId
for this RM attempt.public ApplicationSubmissionContext getSubmissionContext()
RMAppAttempt
RMAppAttempt
.getSubmissionContext
in interface RMAppAttempt
public FinalApplicationStatus getFinalApplicationStatus()
RMAppAttempt
getFinalApplicationStatus
in interface RMAppAttempt
public RMAppAttemptState getAppAttemptState()
RMAppAttempt
RMAppAttempt
.getAppAttemptState
in interface RMAppAttempt
RMAppAttemptState
of this RMAppAttempt
public String getHost()
RMAppAttempt
RMAppAttempt
is running/ran on.getHost
in interface RMAppAttempt
RMAppAttempt
ran/is running on.public int getRpcPort()
RMAppAttempt
RMAppAttempt
.getRpcPort
in interface RMAppAttempt
RMAppAttempt
to which the clients can connect
to.public String getTrackingUrl()
RMAppAttempt
getTrackingUrl
in interface RMAppAttempt
public String getOriginalTrackingUrl()
RMAppAttempt
getOriginalTrackingUrl
in interface RMAppAttempt
public String getWebProxyBase()
RMAppAttempt
getWebProxyBase
in interface RMAppAttempt
public SecretKey getClientTokenMasterKey()
RMAppAttempt
getClientTokenMasterKey
in interface RMAppAttempt
public Token<AMRMTokenIdentifier> getAMRMToken()
RMAppAttempt
getAMRMToken
in interface RMAppAttempt
public Token<ClientToAMTokenIdentifier> createClientToken(String client)
RMAppAttempt
createClientToken
in interface RMAppAttempt
client
- the name of the client requesting the tokenpublic String getDiagnostics()
RMAppAttempt
getDiagnostics
in interface RMAppAttempt
public void setDiagnostics(String message)
public float getProgress()
RMAppAttempt
getProgress
in interface RMAppAttempt
RMAppAttempt
public List<ContainerStatus> getJustFinishedContainers()
RMAppAttempt
getJustFinishedContainers
in interface RMAppAttempt
public List<ContainerStatus> pullJustFinishedContainers()
RMAppAttempt
pullJustFinishedContainers
in interface RMAppAttempt
public Set<NodeId> getRanNodes()
RMAppAttempt
RMAppAttempt
ran.getRanNodes
in interface RMAppAttempt
RMAppAttempt
public Container getMasterContainer()
RMAppAttempt
getMasterContainer
in interface RMAppAttempt
Container
on which the application master is running.public void handle(RMAppAttemptEvent event)
handle
in interface EventHandler<RMAppAttemptEvent>
public ApplicationResourceUsageReport getApplicationResourceUsageReport()
RMAppAttempt
getApplicationResourceUsageReport
in interface RMAppAttempt
public void recover(RMStateStore.RMState state) throws Exception
recover
in interface Recoverable
Exception
public long getStartTime()
RMAppAttempt
getStartTime
in interface RMAppAttempt
Copyright © 2013 Apache Software Foundation. All rights reserved.