public class AdminService extends AbstractService implements ResourceManagerAdministrationProtocol
Service.STATE
versionID
Constructor and Description |
---|
AdminService(Configuration conf,
ResourceScheduler scheduler,
RMContext rmContext,
NodesListManager nodesListManager,
ClientRMService clientRMService,
ApplicationMasterService applicationMasterService,
ResourceTrackerService resourceTrackerService) |
Modifier and Type | Method and Description |
---|---|
String[] |
getGroupsForUser(String user)
Get the groups which are mapped to the given user.
|
RefreshAdminAclsResponse |
refreshAdminAcls(RefreshAdminAclsRequest request) |
RefreshNodesResponse |
refreshNodes(RefreshNodesRequest request) |
RefreshQueuesResponse |
refreshQueues(RefreshQueuesRequest request) |
RefreshServiceAclsResponse |
refreshServiceAcls(RefreshServiceAclsRequest request) |
RefreshSuperUserGroupsConfigurationResponse |
refreshSuperUserGroupsConfiguration(RefreshSuperUserGroupsConfigurationRequest request) |
RefreshUserToGroupsMappingsResponse |
refreshUserToGroupsMappings(RefreshUserToGroupsMappingsRequest request) |
void |
serviceInit(Configuration conf)
All initialization code needed by a service.
|
protected void |
serviceStart()
Actions called during the INITED to STARTED transition.
|
protected void |
serviceStop()
Actions called during the transition to the STOPPED state.
|
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public AdminService(Configuration conf, ResourceScheduler scheduler, RMContext rmContext, NodesListManager nodesListManager, ClientRMService clientRMService, ApplicationMasterService applicationMasterService, ResourceTrackerService resourceTrackerService)
public void serviceInit(Configuration conf) throws Exception
AbstractService
AbstractService.init(Configuration)
prevents re-entrancy.
The base implementation checks to see if the subclass has created
a new configuration instance, and if so, updates the base class valueserviceInit
in class AbstractService
conf
- configurationException
- on a failure -these will be caught,
possibly wrapped, and wil; trigger a service stopprotected void serviceStart() throws Exception
AbstractService
AbstractService.start()
prevents re-entrancy.serviceStart
in class AbstractService
Exception
- if needed -these will be caught,
wrapped, and trigger a service stopprotected void serviceStop() throws Exception
AbstractService
AbstractService.stop()
prevents re-entrancy.
Implementations MUST write this to be robust against failures, including
checks for null references -and for the first failure to not stop other
attempts to shut down parts of the service.serviceStop
in class AbstractService
Exception
- if needed -these will be caught and logged.public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request) throws YarnException
refreshQueues
in interface ResourceManagerAdministrationProtocol
YarnException
public RefreshNodesResponse refreshNodes(RefreshNodesRequest request) throws YarnException
refreshNodes
in interface ResourceManagerAdministrationProtocol
YarnException
public RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(RefreshSuperUserGroupsConfigurationRequest request) throws YarnException
refreshSuperUserGroupsConfiguration
in interface ResourceManagerAdministrationProtocol
YarnException
public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(RefreshUserToGroupsMappingsRequest request) throws YarnException
refreshUserToGroupsMappings
in interface ResourceManagerAdministrationProtocol
YarnException
public RefreshAdminAclsResponse refreshAdminAcls(RefreshAdminAclsRequest request) throws YarnException
refreshAdminAcls
in interface ResourceManagerAdministrationProtocol
YarnException
public RefreshServiceAclsResponse refreshServiceAcls(RefreshServiceAclsRequest request) throws YarnException
refreshServiceAcls
in interface ResourceManagerAdministrationProtocol
YarnException
public String[] getGroupsForUser(String user) throws IOException
GetUserMappingsProtocol
getGroupsForUser
in interface GetUserMappingsProtocol
user
- The user to get the groups for.IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.