org.apache.hadoop.yarn.server.resourcemanager
Class ResourceManager
java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.service.CompositeService
org.apache.hadoop.yarn.server.resourcemanager.ResourceManager
- All Implemented Interfaces:
- Closeable, org.apache.hadoop.service.Service, Recoverable
public class ResourceManager
- extends org.apache.hadoop.service.CompositeService
- implements Recoverable
The ResourceManager is the main class that is a set of components.
"I am the ResourceManager. All your resources belong to us..."
Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService |
org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook |
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service |
org.apache.hadoop.service.Service.STATE |
Fields inherited from class org.apache.hadoop.service.CompositeService |
STOP_ONLY_STARTED_SERVICES |
Methods inherited from class org.apache.hadoop.service.CompositeService |
addIfService, addService, getServices, removeService |
Methods inherited from class org.apache.hadoop.service.AbstractService |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop |
SHUTDOWN_HOOK_PRIORITY
public static final int SHUTDOWN_HOOK_PRIORITY
- Priority of the ResourceManager shutdown hook.
- See Also:
- Constant Field Values
clusterTimeStamp
public static final long clusterTimeStamp
clientToAMSecretManager
protected ClientToAMTokenSecretManagerInRM clientToAMSecretManager
containerTokenSecretManager
protected RMContainerTokenSecretManager containerTokenSecretManager
nmTokenSecretManager
protected NMTokenSecretManagerInRM nmTokenSecretManager
amRmTokenSecretManager
protected AMRMTokenSecretManager amRmTokenSecretManager
scheduler
protected ResourceScheduler scheduler
masterService
protected ApplicationMasterService masterService
nmLivelinessMonitor
protected NMLivelinessMonitor nmLivelinessMonitor
nodesListManager
protected NodesListManager nodesListManager
rmAppManager
protected RMAppManager rmAppManager
applicationACLsManager
protected org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager
queueACLsManager
protected QueueACLsManager queueACLsManager
rmDTSecretManager
protected RMDelegationTokenSecretManager rmDTSecretManager
rmContext
protected RMContext rmContext
resourceTracker
protected ResourceTrackerService resourceTracker
ResourceManager
public ResourceManager()
getRMContext
public RMContext getRMContext()
serviceInit
protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
throws Exception
- Overrides:
serviceInit
in class org.apache.hadoop.service.CompositeService
- Throws:
Exception
createQueueACLsManager
protected QueueACLsManager createQueueACLsManager(ResourceScheduler scheduler,
org.apache.hadoop.conf.Configuration conf)
setRMStateStore
protected void setRMStateStore(RMStateStore rmStore)
createContainerTokenSecretManager
protected RMContainerTokenSecretManager createContainerTokenSecretManager(org.apache.hadoop.conf.Configuration conf)
createNMTokenSecretManager
protected NMTokenSecretManagerInRM createNMTokenSecretManager(org.apache.hadoop.conf.Configuration conf)
createSchedulerEventDispatcher
protected org.apache.hadoop.yarn.event.EventHandler<SchedulerEvent> createSchedulerEventDispatcher()
createDispatcher
protected org.apache.hadoop.yarn.event.Dispatcher createDispatcher()
createAMRMTokenSecretManager
protected AMRMTokenSecretManager createAMRMTokenSecretManager(org.apache.hadoop.conf.Configuration conf)
createScheduler
protected ResourceScheduler createScheduler()
createAMLauncher
protected ApplicationMasterLauncher createAMLauncher()
createAMLivelinessMonitor
protected AMLivelinessMonitor createAMLivelinessMonitor()
createDelegationTokenRenewer
protected DelegationTokenRenewer createDelegationTokenRenewer()
createRMAppManager
protected RMAppManager createRMAppManager()
validateConfigs
protected static void validateConfigs(org.apache.hadoop.conf.Configuration conf)
createPolicyMonitors
protected void createPolicyMonitors()
startWepApp
protected void startWepApp()
serviceStart
protected void serviceStart()
throws Exception
- Overrides:
serviceStart
in class org.apache.hadoop.service.CompositeService
- Throws:
Exception
doSecureLogin
protected void doSecureLogin()
throws IOException
- Throws:
IOException
serviceStop
protected void serviceStop()
throws Exception
- Overrides:
serviceStop
in class org.apache.hadoop.service.CompositeService
- Throws:
Exception
createResourceTrackerService
protected ResourceTrackerService createResourceTrackerService()
createRMDelegationTokenSecretManager
protected RMDelegationTokenSecretManager createRMDelegationTokenSecretManager(RMContext rmContext)
createClientRMService
protected ClientRMService createClientRMService()
createApplicationMasterService
protected ApplicationMasterService createApplicationMasterService()
createAdminService
protected AdminService createAdminService(ClientRMService clientRMService,
ApplicationMasterService applicationMasterService,
ResourceTrackerService resourceTrackerService)
getClientRMService
@InterfaceAudience.Private
public ClientRMService getClientRMService()
getResourceScheduler
@InterfaceAudience.Private
public ResourceScheduler getResourceScheduler()
- return the scheduler.
- Returns:
- the scheduler for the Resource Manager.
getResourceTrackerService
@InterfaceAudience.Private
public ResourceTrackerService getResourceTrackerService()
- return the resource tracking component.
- Returns:
- the resource tracking component.
getApplicationMasterService
@InterfaceAudience.Private
public ApplicationMasterService getApplicationMasterService()
getApplicationACLsManager
@InterfaceAudience.Private
public org.apache.hadoop.yarn.server.security.ApplicationACLsManager getApplicationACLsManager()
getQueueACLsManager
@InterfaceAudience.Private
public QueueACLsManager getQueueACLsManager()
getRMContainerTokenSecretManager
@InterfaceAudience.Private
public RMContainerTokenSecretManager getRMContainerTokenSecretManager()
getRMNMTokenSecretManager
@InterfaceAudience.Private
public NMTokenSecretManagerInRM getRMNMTokenSecretManager()
getAMRMTokenSecretManager
@InterfaceAudience.Private
public AMRMTokenSecretManager getAMRMTokenSecretManager()
recover
public void recover(RMStateStore.RMState state)
throws Exception
- Specified by:
recover
in interface Recoverable
- Throws:
Exception
main
public static void main(String[] argv)
Copyright © 2014 Apache Software Foundation. All Rights Reserved.