public class AdminService
extends org.apache.hadoop.service.CompositeService
implements org.apache.hadoop.ha.HAServiceProtocol, org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook
Constructor and Description |
---|
AdminService(ResourceManager rm,
RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse |
addToClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest request) |
protected EmbeddedElectorService |
createEmbeddedElectorService() |
org.apache.hadoop.security.authorize.AccessControlList |
getAccessControlList() |
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse |
getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) |
String[] |
getGroupsForUser(String user) |
org.apache.hadoop.ipc.RPC.Server |
getServer() |
org.apache.hadoop.ha.HAServiceStatus |
getServiceStatus() |
void |
monitorHealth() |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse |
refreshAdminAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest request) |
org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsResponse |
refreshClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResponse |
refreshNodes(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse |
refreshQueues(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsResponse |
refreshServiceAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse |
refreshSuperUserGroupsConfiguration(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse |
refreshUserToGroupsMappings(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsResponse |
removeFromClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeResponse |
replaceLabelsOnNode(org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeRequest request) |
void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
protected void |
startServer() |
protected void |
stopServer() |
void |
transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo) |
void |
transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo) |
org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse |
updateNodeResource(org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest request) |
addIfService, addService, getServices, removeService
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(ResourceManager rm, RMContext rmContext)
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
protected EmbeddedElectorService createEmbeddedElectorService()
public void monitorHealth() throws IOException
monitorHealth
in interface org.apache.hadoop.ha.HAServiceProtocol
IOException
public void transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo) throws IOException
transitionToActive
in interface org.apache.hadoop.ha.HAServiceProtocol
IOException
public void transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo) throws IOException
transitionToStandby
in interface org.apache.hadoop.ha.HAServiceProtocol
IOException
public org.apache.hadoop.ha.HAServiceStatus getServiceStatus() throws IOException
getServiceStatus
in interface org.apache.hadoop.ha.HAServiceProtocol
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse refreshQueues(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, org.apache.hadoop.ipc.StandbyException
refreshQueues
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.ipc.StandbyException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResponse refreshNodes(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, org.apache.hadoop.ipc.StandbyException
refreshNodes
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.ipc.StandbyException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshSuperUserGroupsConfiguration
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshUserToGroupsMappings
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse refreshAdminAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshAdminAcls
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsResponse refreshServiceAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshServiceAcls
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public String[] getGroupsForUser(String user) throws IOException
getGroupsForUser
in interface org.apache.hadoop.tools.GetUserMappingsProtocol
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse updateNodeResource(org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
updateNodeResource
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.security.authorize.AccessControlList getAccessControlList()
public org.apache.hadoop.ipc.RPC.Server getServer()
public org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse addToClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
addToClusterNodeLabels
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsResponse removeFromClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
removeFromClusterNodeLabels
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeResponse replaceLabelsOnNode(org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
replaceLabelsOnNode
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
getClusterNodeLabels
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsResponse refreshClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.RefreshClusterNodeLabelsRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
refreshClusterNodeLabels
in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol
org.apache.hadoop.yarn.exceptions.YarnException
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.