@InterfaceAudience.Private public static final class User.SecureHadoopUser extends User
User invocations to underlying calls to
UserGroupInformation for secure Hadoop
0.20 and versions 0.21 and above.User.SecureHadoopUserHBASE_SECURITY_AUTHORIZATION_CONF_KEY, HBASE_SECURITY_CONF_KEY, ugi| Constructor and Description |
|---|
User.SecureHadoopUser() |
User.SecureHadoopUser(org.apache.hadoop.security.UserGroupInformation ugi) |
User.SecureHadoopUser(org.apache.hadoop.security.UserGroupInformation ugi,
com.google.common.cache.LoadingCache<String,String[]> cache) |
| Modifier and Type | Method and Description |
|---|---|
static User |
createUserForTesting(org.apache.hadoop.conf.Configuration conf,
String name,
String[] groups) |
String[] |
getGroupNames()
Returns the list of groups of which this user is a member.
|
String |
getShortName()
Returns the shortened version of the user name -- the portion that maps
to an operating system user name.
|
static boolean |
isSecurityEnabled()
Returns the result of
UserGroupInformation.isSecurityEnabled(). |
static void |
login(org.apache.hadoop.conf.Configuration conf,
String fileConfKey,
String principalConfKey,
String localhost)
Obtain credentials for the current process using the configured
Kerberos keytab file and principal.
|
void |
obtainAuthTokenForJob(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapreduce.Job job)
Requests an authentication token for this user and stores it in the
user's credentials.
|
void |
obtainAuthTokenForJob(org.apache.hadoop.mapred.JobConf job)
Requests an authentication token for this user and stores it in the
user's credentials.
|
<T> T |
runAs(PrivilegedAction<T> action)
Executes the given action within the context of this user.
|
<T> T |
runAs(PrivilegedExceptionAction<T> action)
Executes the given action within the context of this user.
|
addToken, create, equals, getCurrent, getName, getToken, getTokens, getUGI, hashCode, isHBaseSecurityEnabled, runAsLoginUser, toStringpublic User.SecureHadoopUser()
throws IOException
IOExceptionpublic User.SecureHadoopUser(org.apache.hadoop.security.UserGroupInformation ugi)
public String getShortName()
UsergetShortName in class Userpublic String[] getGroupNames()
UsergetGroupNames in class Userpublic <T> T runAs(PrivilegedAction<T> action)
Userpublic <T> T runAs(PrivilegedExceptionAction<T> action) throws IOException, InterruptedException
UserrunAs in class UserIOExceptionInterruptedExceptionpublic void obtainAuthTokenForJob(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapreduce.Job job)
throws IOException,
InterruptedException
UserobtainAuthTokenForJob in class UserIOExceptionInterruptedExceptionpublic void obtainAuthTokenForJob(org.apache.hadoop.mapred.JobConf job)
throws IOException,
InterruptedException
UserobtainAuthTokenForJob in class UserIOExceptionInterruptedExceptionpublic static User createUserForTesting(org.apache.hadoop.conf.Configuration conf, String name, String[] groups)
public static void login(org.apache.hadoop.conf.Configuration conf,
String fileConfKey,
String principalConfKey,
String localhost)
throws IOException
conf - the Configuration to usefileConfKey - Configuration property key used to store the path
to the keytab fileprincipalConfKey - Configuration property key used to store the
principal name to login aslocalhost - the local hostnameIOExceptionUser.login(org.apache.hadoop.conf.Configuration, String, String, String)public static boolean isSecurityEnabled()
UserGroupInformation.isSecurityEnabled().Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.