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

java.lang.Object
  extended by 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.


Constructor Summary
RMAppManager(RMContext context, YarnScheduler scheduler, ApplicationMasterService masterService, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, org.apache.hadoop.conf.Configuration conf)
           
 
Method Summary
protected  void checkAppNumCompletedLimit()
           
protected  void finishApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
           
protected  int getCompletedAppsListSize()
           
 void handle(RMAppManagerEvent event)
           
 void recover(RMStateStore.RMState state)
           
protected  void setCompletedAppsMax(int max)
           
protected  void submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, long submitTime, boolean isRecovered, 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
 

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

setCompletedAppsMax

protected void setCompletedAppsMax(int max)

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,
                                 boolean isRecovered,
                                 String user)
                          throws org.apache.hadoop.yarn.exceptions.YarnException
Throws:
org.apache.hadoop.yarn.exceptions.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 org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>


Copyright © 2014 Apache Software Foundation. All Rights Reserved.