Package org.apache.hadoop.yarn.server.router.rmadmin

Class DefaultRMAdminRequestInterceptor

java.lang.Object

org.apache.hadoop.yarn.server.router.rmadmin.AbstractRMAdminRequestInterceptor

org.apache.hadoop.yarn.server.router.rmadmin.DefaultRMAdminRequestInterceptor

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.tools.GetUserMappingsProtocol, org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol, RMAdminRequestInterceptor

public class DefaultRMAdminRequestInterceptor
extends AbstractRMAdminRequestInterceptor

Extends the AbstractRMAdminRequestInterceptor class and provides an implementation that simply forwards the client requests to the cluster resource manager.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.router.rmadmin.AbstractRMAdminRequestInterceptor

user

Fields inherited from interface org.apache.hadoop.tools.GetUserMappingsProtocol

versionID

Constructor Summary

Constructors

Constructor	Description
DefaultRMAdminRequestInterceptor()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse	addToClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesResponse	batchSaveFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesResponse	checkForDecommissioningNodes(org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesRequest checkForDecommissioningNodesRequest)
org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationResponse	deleteFederationApplication(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesResponse	deleteFederationPoliciesByQueues(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterResponse	deregisterSubCluster(org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersResponse	getFederationSubClusters(org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersRequest request)
String[]	getGroupsForUser(String userName)
void	init(String userName)	Initializes the RMAdminRequestInterceptor.
org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesResponse	listFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingResponse	mapAttributesToNodes(org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse	refreshAdminAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityResponse	refreshClusterMaxPriority(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityRequest 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.RefreshNodesResourcesResponse	refreshNodesResources(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesRequest 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)
org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyResponse	saveFederationQueuePolicy(org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyRequest request)
void	setNextInterceptor(RMAdminRequestInterceptor next)	Sets the RMAdminRequestInterceptor in the chain.
void	setRMAdmin(org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol rmAdmin)
org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse	updateNodeResource(org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest request)

Methods inherited from class org.apache.hadoop.yarn.server.router.rmadmin.AbstractRMAdminRequestInterceptor

getConf, getNextInterceptor, setConf, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultRMAdminRequestInterceptor

public DefaultRMAdminRequestInterceptor()

Method Details

init

public void init(String userName)

Description copied from class: AbstractRMAdminRequestInterceptor

Initializes the RMAdminRequestInterceptor.

Specified by:

init in interface RMAdminRequestInterceptor

Overrides:

init in class AbstractRMAdminRequestInterceptor

Parameters:

userName - the name of the client

setNextInterceptor

public void setNextInterceptor(RMAdminRequestInterceptor next)

Description copied from class: AbstractRMAdminRequestInterceptor

Sets the RMAdminRequestInterceptor in the chain.

Specified by:

setNextInterceptor in interface RMAdminRequestInterceptor

Overrides:

setNextInterceptor in class AbstractRMAdminRequestInterceptor

Parameters:

next - the RMAdminRequestInterceptor to set in the pipeline

setRMAdmin

@VisibleForTesting
public void setRMAdmin(org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol rmAdmin)

refreshQueues

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse refreshQueues(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest request)
                                                                                      throws org.apache.hadoop.ipc.StandbyException,
org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.ipc.StandbyException

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResponse refreshNodes(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest request)
                                                                                    throws org.apache.hadoop.ipc.StandbyException,
org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.ipc.StandbyException

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshSuperUserGroupsConfiguration

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest request)
                                                                                                                                  throws org.apache.hadoop.ipc.StandbyException,
org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.ipc.StandbyException

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshUserToGroupsMappings

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest request)
                                                                                                                  throws org.apache.hadoop.ipc.StandbyException,
org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.ipc.StandbyException

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshAdminAcls

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshServiceAcls

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateNodeResource

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshNodesResources

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesResponse refreshNodesResources(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesRequest request)
                                                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

addToClusterNodeLabels

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

removeFromClusterNodeLabels

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

replaceLabelsOnNode

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

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

checkForDecommissioningNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesResponse checkForDecommissioningNodes(org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesRequest checkForDecommissioningNodesRequest)
                                                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshClusterMaxPriority

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityResponse refreshClusterMaxPriority(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityRequest request)
                                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getGroupsForUser

public String[] getGroupsForUser(String userName)
                          throws IOException

Throws:

IOException

mapAttributesToNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingResponse mapAttributesToNodes(org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingRequest request)
                                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deregisterSubCluster

public org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterResponse deregisterSubCluster(org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterRequest request)
                                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

saveFederationQueuePolicy

public org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyResponse saveFederationQueuePolicy(org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyRequest request)
                                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

batchSaveFederationQueuePolicies

public org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesResponse batchSaveFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesRequest request)
                                                                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

listFederationQueuePolicies

public org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesResponse listFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesRequest request)
                                                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteFederationApplication

public org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationResponse deleteFederationApplication(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationRequest request)
                                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getFederationSubClusters

public org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersResponse getFederationSubClusters(org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersRequest request)
                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteFederationPoliciesByQueues

public org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesResponse deleteFederationPoliciesByQueues(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException