org.apache.hadoop.yarn.server.resourcemanager

Class RMAppManager

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.RMAppManager

All Implemented Interfaces:

org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>, Recoverable

public class RMAppManager
extends Object
implements org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>, Recoverable

This class manages the list of applications for the resource manager.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	completedAppsInStateStore

Constructor Summary

Constructors

Constructor and Description
RMAppManager(RMContext context, YarnScheduler scheduler, ApplicationMasterService masterService, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkAppNumCompletedLimit()
protected void	finishApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
protected int	getCompletedAppsListSize()
void	handle(RMAppManagerEvent event)
void	logApplicationSummary(org.apache.hadoop.yarn.api.records.ApplicationId appId)
protected org.apache.hadoop.security.Credentials	parseCredentials(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext application)
void	recover(RMStateStore.RMState state)
protected void	recoverApplication(ApplicationStateData appState, RMStateStore.RMState rmState)
protected void	submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, long submitTime, String user)
protected void	writeAuditLog(org.apache.hadoop.yarn.api.records.ApplicationId appId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

completedAppsInStateStore

protected int completedAppsInStateStore

Constructor Detail

RMAppManager

public RMAppManager(RMContext context,
            YarnScheduler scheduler,
            ApplicationMasterService masterService,
            org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
            org.apache.hadoop.conf.Configuration conf)

Method Detail

logApplicationSummary

public void logApplicationSummary(org.apache.hadoop.yarn.api.records.ApplicationId appId)

getCompletedAppsListSize

protected int getCompletedAppsListSize()

finishApplication

protected void finishApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

writeAuditLog

protected void writeAuditLog(org.apache.hadoop.yarn.api.records.ApplicationId appId)

checkAppNumCompletedLimit

protected void checkAppNumCompletedLimit()

submitApplication

protected void submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
                     long submitTime,
                     String user)
                          throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

recoverApplication

protected void recoverApplication(ApplicationStateData appState,
                      RMStateStore.RMState rmState)
                           throws Exception

Throws:

Exception

parseCredentials

protected org.apache.hadoop.security.Credentials parseCredentials(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext application)
                                                           throws IOException

Throws:

IOException

recover

public void recover(RMStateStore.RMState state)
             throws Exception

Specified by:

recover in interface Recoverable

Throws:

Exception

handle

public void handle(RMAppManagerEvent event)

Specified by:

handle in interface org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>