public class RMAppManager extends Object implements EventHandler<RMAppManagerEvent>, Recoverable
Constructor and Description |
---|
RMAppManager(RMContext context,
YarnScheduler scheduler,
ApplicationMasterService masterService,
ApplicationACLsManager applicationACLsManager,
Configuration conf) |
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) |
public RMAppManager(RMContext context, YarnScheduler scheduler, ApplicationMasterService masterService, ApplicationACLsManager applicationACLsManager, Configuration conf)
protected void setCompletedAppsMax(int max)
protected int getCompletedAppsListSize()
protected void finishApplication(ApplicationId applicationId)
protected void writeAuditLog(ApplicationId appId)
protected void checkAppNumCompletedLimit()
protected void submitApplication(ApplicationSubmissionContext submissionContext, long submitTime, boolean isRecovered, String user) throws YarnException
YarnException
public void recover(RMStateStore.RMState state) throws Exception
recover
in interface Recoverable
Exception
public void handle(RMAppManagerEvent event)
handle
in interface EventHandler<RMAppManagerEvent>
Copyright © 2013 Apache Software Foundation. All rights reserved.