| Package | Description |
|---|---|
| org.apache.hadoop.fs |
An abstract file system API.
|
| org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
| org.apache.hadoop.security | |
| org.apache.hadoop.security.authorize | |
| org.apache.hadoop.security.token | |
| org.apache.hadoop.security.token.delegation | |
| org.apache.hadoop.util |
Common utilities.
|
| Modifier and Type | Method and Description |
|---|---|
UserGroupInformation |
FileContext.getUgi()
Gets the ugi in the file-context
|
| Modifier and Type | Method and Description |
|---|---|
static void |
FileSystem.closeAllForUGI(UserGroupInformation ugi)
Close all cached filesystems for a given UGI.
|
| Modifier and Type | Field and Description |
|---|---|
UserGroupInformation |
Server.Connection.attemptingUser |
| Modifier and Type | Method and Description |
|---|---|
static UserGroupInformation |
Server.getRemoteUser()
Returns the RPC remote user when invoked inside an RPC.
|
UserGroupInformation |
Server.Call.getRemoteUser() |
abstract UserGroupInformation |
ExternalCall.getRemoteUser() |
UserGroupInformation |
Server.Call.getUserGroupInformation() |
| Modifier and Type | Method and Description |
|---|---|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout) |
<T> ProtocolProxy<T> |
WritableRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
<T> ProtocolProxy<T> |
RpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object.
|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy) |
<T> ProtocolProxy<T> |
WritableRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
<T> ProtocolProxy<T> |
RpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth)
Construct a client-side proxy object.
|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth) |
| Modifier and Type | Method and Description |
|---|---|
static UserGroupInformation |
UserGroupInformation.createProxyUser(String user,
UserGroupInformation realUser)
Create a proxy user using username of the effective user and the ugi of the
real user.
|
static UserGroupInformation |
UserGroupInformation.createProxyUserForTesting(String user,
UserGroupInformation realUser,
String[] userGroups)
Create a proxy user UGI for testing HDFS and MapReduce
|
static UserGroupInformation |
UserGroupInformation.createRemoteUser(String user)
Create a user from a login name.
|
static UserGroupInformation |
UserGroupInformation.createRemoteUser(String user,
SaslRpcServer.AuthMethod authMethod)
Create a user from a login name.
|
static UserGroupInformation |
UserGroupInformation.createUserForTesting(String user,
String[] userGroups)
Create a UGI for testing HDFS and MapReduce
|
static UserGroupInformation |
UserGroupInformation.getBestUGI(String ticketCachePath,
String user)
Find the most appropriate UserGroupInformation to use
|
static UserGroupInformation |
UserGroupInformation.getCurrentUser()
Return the current user, including any doAs in the current stack.
|
static UserGroupInformation |
UserGroupInformation.getLoginUser()
Get the currently logged in user.
|
UserGroupInformation |
UserGroupInformation.getRealUser()
get RealUser (vs.
|
static UserGroupInformation |
UserGroupInformation.getUGIFromSubject(Subject subject)
Create a UserGroupInformation from a Subject with Kerberos principal.
|
static UserGroupInformation |
UserGroupInformation.getUGIFromTicketCache(String ticketCache,
String user)
Create a UserGroupInformation from a Kerberos ticket cache.
|
static UserGroupInformation |
UserGroupInformation.loginUserFromKeytabAndReturnUGI(String user,
String path)
Log a user in from a keytab file.
|
| Modifier and Type | Method and Description |
|---|---|
static UserGroupInformation |
UserGroupInformation.createProxyUser(String user,
UserGroupInformation realUser)
Create a proxy user using username of the effective user and the ugi of the
real user.
|
static UserGroupInformation |
UserGroupInformation.createProxyUserForTesting(String user,
UserGroupInformation realUser,
String[] userGroups)
Create a proxy user UGI for testing HDFS and MapReduce
|
void |
KDiag.dumpTokens(UserGroupInformation ugi)
Dump all tokens of a UGI.
|
static UserGroupInformation.AuthenticationMethod |
UserGroupInformation.getRealAuthenticationMethod(UserGroupInformation ugi)
Returns the authentication method of a ugi.
|
static void |
UserGroupInformation.logAllUserInfo(UserGroupInformation ugi) |
| Modifier and Type | Method and Description |
|---|---|
void |
ImpersonationProvider.authorize(UserGroupInformation user,
String remoteAddress)
Authorize the superuser which is doing doAs
|
void |
DefaultImpersonationProvider.authorize(UserGroupInformation user,
String remoteAddress) |
boolean |
AccessControlList.isUserAllowed(UserGroupInformation ugi) |
boolean |
AccessControlList.isUserInList(UserGroupInformation ugi)
Checks if a user represented by the provided
UserGroupInformation
is a member of the Access Control List |
| Modifier and Type | Method and Description |
|---|---|
abstract UserGroupInformation |
TokenIdentifier.getUser()
Get the Ugi with the username encoded in the token identifier
|
| Modifier and Type | Method and Description |
|---|---|
UserGroupInformation |
AbstractDelegationTokenIdentifier.getUser()
Get the username encoded in the token identifier
|
| Modifier and Type | Method and Description |
|---|---|
static UserGroupInformation |
ProtoUtil.getUgi(IpcConnectionContextProtos.IpcConnectionContextProto context) |
static UserGroupInformation |
ProtoUtil.getUgi(IpcConnectionContextProtos.UserInformationProto userInfo) |
| Modifier and Type | Method and Description |
|---|---|
static IpcConnectionContextProtos.IpcConnectionContextProto |
ProtoUtil.makeIpcConnectionContext(String protocol,
UserGroupInformation ugi,
SaslRpcServer.AuthMethod authMethod)
This method creates the connection context using exactly the same logic
as the old connection context as was done for writable where
the effective and real users are set based on the auth method.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.