@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.SecureHadoopUser, User.TestingGroups
Modifier and Type | Field and Description |
---|---|
private com.google.common.cache.LoadingCache<String,String[]> |
cache |
private String |
shortName |
HBASE_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, toString
private String shortName
public User.SecureHadoopUser() throws IOException
IOException
public User.SecureHadoopUser(org.apache.hadoop.security.UserGroupInformation ugi)
public String getShortName()
User
getShortName
in class User
public String[] getGroupNames()
User
getGroupNames
in class User
public <T> T runAs(PrivilegedAction<T> action)
User
public <T> T runAs(PrivilegedExceptionAction<T> action) throws IOException, InterruptedException
User
runAs
in class User
IOException
InterruptedException
public void obtainAuthTokenForJob(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.Job job) throws IOException, InterruptedException
User
obtainAuthTokenForJob
in class User
IOException
InterruptedException
public void obtainAuthTokenForJob(org.apache.hadoop.mapred.JobConf job) throws IOException, InterruptedException
User
obtainAuthTokenForJob
in class User
IOException
InterruptedException
public 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 hostnameIOException
User.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.