org.apache.hive.service.auth

Class HiveAuthFactory

java.lang.Object

org.apache.hive.service.auth.HiveAuthFactory

public class HiveAuthFactory
extends Object

This class helps in some aspects of authentication. It creates the proper Thrift classes for the given configuration as well as helps with authenticating requests.

Constructor Summary

Constructors

Constructor and Description
HiveAuthFactory(HiveConf conf)

Method Summary

Modifier and Type	Method and Description
void	cancelDelegationToken(String delegationToken)
org.apache.thrift.TProcessorFactory	getAuthProcFactory(ThriftCLIService service) Returns the thrift processor factory for HiveServer2 running in binary mode
org.apache.thrift.transport.TTransportFactory	getAuthTransFactory()
String	getDelegationToken(String owner, String renewer, String remoteAddr)
String	getIpAddress()
String	getRemoteUser()
Map<String,String>	getSaslProperties()
String	getUserAuthMechanism()
String	getUserFromToken(String delegationToken)
boolean	isSASLKerberosUser()
boolean	isSASLWithKerberizedHadoop()
static void	loginFromKeytab(HiveConf hiveConf)
static org.apache.hadoop.security.UserGroupInformation	loginFromSpnegoKeytabAndReturnUGI(HiveConf hiveConf)
void	renewDelegationToken(String delegationToken)
String	verifyDelegationToken(String delegationToken)
static void	verifyProxyAccess(String realUser, String proxyUser, String ipAddress, HiveConf hiveConf)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveAuthFactory

public HiveAuthFactory(HiveConf conf)
                throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

Method Detail

getSaslProperties

public Map<String,String> getSaslProperties()

getAuthTransFactory

public org.apache.thrift.transport.TTransportFactory getAuthTransFactory()
                                                                  throws LoginException

Throws:

LoginException

getAuthProcFactory

public org.apache.thrift.TProcessorFactory getAuthProcFactory(ThriftCLIService service)
                                                       throws LoginException

Returns the thrift processor factory for HiveServer2 running in binary mode

Parameters:

service -

Returns:

Throws:

LoginException

getRemoteUser

public String getRemoteUser()

getIpAddress

public String getIpAddress()

getUserAuthMechanism

public String getUserAuthMechanism()

isSASLWithKerberizedHadoop

public boolean isSASLWithKerberizedHadoop()

isSASLKerberosUser

public boolean isSASLKerberosUser()

loginFromKeytab

public static void loginFromKeytab(HiveConf hiveConf)
                            throws IOException

Throws:

IOException

loginFromSpnegoKeytabAndReturnUGI

public static org.apache.hadoop.security.UserGroupInformation loginFromSpnegoKeytabAndReturnUGI(HiveConf hiveConf)
                                                                                         throws IOException

Throws:

IOException

getDelegationToken

public String getDelegationToken(String owner,
                                 String renewer,
                                 String remoteAddr)
                          throws HiveSQLException

Throws:

HiveSQLException

cancelDelegationToken

public void cancelDelegationToken(String delegationToken)
                           throws HiveSQLException

Throws:

HiveSQLException

renewDelegationToken

public void renewDelegationToken(String delegationToken)
                          throws HiveSQLException

Throws:

HiveSQLException

verifyDelegationToken

public String verifyDelegationToken(String delegationToken)
                             throws HiveSQLException

Throws:

HiveSQLException

getUserFromToken

public String getUserFromToken(String delegationToken)
                        throws HiveSQLException

Throws:

HiveSQLException

verifyProxyAccess

public static void verifyProxyAccess(String realUser,
                                     String proxyUser,
                                     String ipAddress,
                                     HiveConf hiveConf)
                              throws HiveSQLException

Throws:

HiveSQLException