org.apache.hadoop.yarn.server.resourcemanager

Class RMAppManager

java.lang.Object

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

All Implemented Interfaces:

EventHandler<RMAppManagerEvent>, Recoverable

public class RMAppManager
extends Object
implements EventHandler<RMAppManagerEvent>, Recoverable

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

Constructor Summary

Constructors

Constructor and Description
RMAppManager(RMContext context, YarnScheduler scheduler, ApplicationMasterService masterService, ApplicationACLsManager applicationACLsManager, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkAppNumCompletedLimit()
protected void	finishApplication(ApplicationId applicationId)
protected int	getCompletedAppsListSize()
void	handle(RMAppManagerEvent event)
void	recover(RMStateStore.RMState state)
protected void	setCompletedAppsMax(int max)
protected void	submitApplication(ApplicationSubmissionContext submissionContext, long submitTime, boolean isRecovered, String user)
protected void	writeAuditLog(ApplicationId appId)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMAppManager

public RMAppManager(RMContext context,
            YarnScheduler scheduler,
            ApplicationMasterService masterService,
            ApplicationACLsManager applicationACLsManager,
            Configuration conf)

Method Detail

setCompletedAppsMax

protected void setCompletedAppsMax(int max)

getCompletedAppsListSize

protected int getCompletedAppsListSize()

finishApplication

protected void finishApplication(ApplicationId applicationId)

writeAuditLog

protected void writeAuditLog(ApplicationId appId)

checkAppNumCompletedLimit

protected void checkAppNumCompletedLimit()

submitApplication

protected void submitApplication(ApplicationSubmissionContext submissionContext,
                     long submitTime,
                     boolean isRecovered,
                     String user)
                          throws YarnException

Throws:

YarnException

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 EventHandler<RMAppManagerEvent>