|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttemptImpl
public class RMAppAttemptImpl
Field Summary | |
---|---|
static org.apache.hadoop.yarn.api.records.Priority |
AM_CONTAINER_PRIORITY
|
Constructor Summary | |
---|---|
RMAppAttemptImpl(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
RMContext rmContext,
YarnScheduler scheduler,
ApplicationMasterService masterService,
org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
org.apache.hadoop.conf.Configuration conf,
String user)
|
Method Summary | |
---|---|
org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.client.ClientToAMTokenIdentifier> |
createClientToken(String client)
Create a token for authenticating a client connection to the app attempt |
org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier> |
getAMRMToken()
The AMRMToken belonging to this app attempt |
org.apache.hadoop.yarn.api.records.ApplicationAttemptId |
getAppAttemptId()
Get the application attempt id for this RMAppAttempt . |
RMAppAttemptState |
getAppAttemptState()
The state of the RMAppAttempt . |
org.apache.hadoop.yarn.api.records.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. |
org.apache.hadoop.yarn.api.records.FinalApplicationStatus |
getFinalApplicationStatus()
The final status set by the AM. |
String |
getHost()
The host on which the RMAppAttempt is running/ran on. |
List<org.apache.hadoop.yarn.api.records.ContainerStatus> |
getJustFinishedContainers()
Return the list of last set of finished containers. |
org.apache.hadoop.yarn.api.records.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<org.apache.hadoop.yarn.api.records.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. |
org.apache.hadoop.yarn.api.records.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<org.apache.hadoop.yarn.api.records.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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.hadoop.yarn.api.records.Priority AM_CONTAINER_PRIORITY
Constructor Detail |
---|
public RMAppAttemptImpl(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, RMContext rmContext, YarnScheduler scheduler, ApplicationMasterService masterService, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, org.apache.hadoop.conf.Configuration conf, String user)
Method Detail |
---|
public org.apache.hadoop.yarn.api.records.ApplicationAttemptId getAppAttemptId()
RMAppAttempt
RMAppAttempt
.
getAppAttemptId
in interface RMAppAttempt
ApplicationAttemptId
for this RM attempt.public org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext getSubmissionContext()
RMAppAttempt
RMAppAttempt
.
getSubmissionContext
in interface RMAppAttempt
public org.apache.hadoop.yarn.api.records.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 org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.AMRMTokenIdentifier> getAMRMToken()
RMAppAttempt
getAMRMToken
in interface RMAppAttempt
public org.apache.hadoop.security.token.Token<org.apache.hadoop.yarn.security.client.ClientToAMTokenIdentifier> createClientToken(String client)
RMAppAttempt
createClientToken
in interface RMAppAttempt
client
- the name of the client requesting the token
public String getDiagnostics()
RMAppAttempt
getDiagnostics
in interface RMAppAttempt
public void setDiagnostics(String message)
public float getProgress()
RMAppAttempt
getProgress
in interface RMAppAttempt
RMAppAttempt
public List<org.apache.hadoop.yarn.api.records.ContainerStatus> getJustFinishedContainers()
RMAppAttempt
getJustFinishedContainers
in interface RMAppAttempt
public List<org.apache.hadoop.yarn.api.records.ContainerStatus> pullJustFinishedContainers()
RMAppAttempt
pullJustFinishedContainers
in interface RMAppAttempt
public Set<org.apache.hadoop.yarn.api.records.NodeId> getRanNodes()
RMAppAttempt
RMAppAttempt
ran.
getRanNodes
in interface RMAppAttempt
RMAppAttempt
public org.apache.hadoop.yarn.api.records.Container getMasterContainer()
RMAppAttempt
getMasterContainer
in interface RMAppAttempt
Container
on which the application master is running.public void handle(RMAppAttemptEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<RMAppAttemptEvent>
public org.apache.hadoop.yarn.api.records.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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |