org.apache.hadoop.yarn.server.api.impl.pb.client

Class ResourceManagerAdministrationProtocolPBClientImpl

java.lang.Object

org.apache.hadoop.yarn.server.api.impl.pb.client.ResourceManagerAdministrationProtocolPBClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, GetUserMappingsProtocol, ResourceManagerAdministrationProtocol

@InterfaceAudience.Private
public class ResourceManagerAdministrationProtocolPBClientImpl
extends Object
implements ResourceManagerAdministrationProtocol, Closeable

Field Summary

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

versionID

Constructor Summary

Constructors

Constructor and Description
ResourceManagerAdministrationProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerAdministrationProtocolPBClientImpl

public ResourceManagerAdministrationProtocolPBClientImpl(long clientVersion,
                                                 InetSocketAddress addr,
                                                 Configuration conf)
                                                  throws IOException

Throws:

IOException

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

refreshQueues

public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request)
                                    throws YarnException,
                                           IOException

Specified by:

refreshQueues in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

refreshNodes

public RefreshNodesResponse refreshNodes(RefreshNodesRequest request)
                                  throws YarnException,
                                         IOException

Specified by:

refreshNodes in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

refreshSuperUserGroupsConfiguration

public RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(RefreshSuperUserGroupsConfigurationRequest request)
                                                                                throws YarnException,
                                                                                       IOException

Specified by:

refreshSuperUserGroupsConfiguration in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

refreshUserToGroupsMappings

public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(RefreshUserToGroupsMappingsRequest request)
                                                                throws YarnException,
                                                                       IOException

Specified by:

refreshUserToGroupsMappings in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

refreshAdminAcls

public RefreshAdminAclsResponse refreshAdminAcls(RefreshAdminAclsRequest request)
                                          throws YarnException,
                                                 IOException

Specified by:

refreshAdminAcls in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

refreshServiceAcls

public RefreshServiceAclsResponse refreshServiceAcls(RefreshServiceAclsRequest request)
                                              throws YarnException,
                                                     IOException

Specified by:

refreshServiceAcls in interface ResourceManagerAdministrationProtocol

Throws:

YarnException

IOException

getGroupsForUser

public String[] getGroupsForUser(String user)
                          throws IOException

Description copied from interface: GetUserMappingsProtocol

Get the groups which are mapped to the given user.

Specified by:

getGroupsForUser in interface GetUserMappingsProtocol

Parameters:

user - The user to get the groups for.

Returns:

The set of groups the user belongs to.

Throws:

IOException