org.apache.hadoop.hive.shims

Class Utils

java.lang.Object

org.apache.hadoop.hive.shims.Utils

public class Utils
extends Object

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Methods

Modifier and Type	Method and Description
static String	addServiceToToken(String tokenStr, String tokenService) Add a given service to delegation token string.
static String	getTokenStrForm(String tokenSignature) Get the string form of the token given a token signature.
static org.apache.hadoop.security.UserGroupInformation	getUGI()
static void	setTokenStr(org.apache.hadoop.security.UserGroupInformation ugi, String tokenStr, String tokenService) Create a delegation token object for the given token string and service.
static void	setZookeeperClientKerberosJaasConfig(String principal, String keyTabFile) Dynamically sets up the JAAS configuration that uses kerberos

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

getUGI

public static org.apache.hadoop.security.UserGroupInformation getUGI()
                                                              throws LoginException,
                                                                     IOException

Throws:

LoginException

IOException

getTokenStrForm

public static String getTokenStrForm(String tokenSignature)
                              throws IOException

Get the string form of the token given a token signature. The signature is used as the value of the "service" field in the token for lookup. Ref: AbstractDelegationTokenSelector in Hadoop. If there exists such a token in the token cache (credential store) of the job, the lookup returns that. This is relevant only when running against a "secure" hadoop release The method gets hold of the tokens if they are set up by hadoop - this should happen on the map/reduce tasks if the client added the tokens into hadoop's credential store in the front end during job submission. The method will select the hive delegation token among the set of tokens and return the string form of it

Parameters:

tokenSignature -

Returns:

the string form of the token found

Throws:

IOException

setTokenStr

public static void setTokenStr(org.apache.hadoop.security.UserGroupInformation ugi,
               String tokenStr,
               String tokenService)
                        throws IOException

Create a delegation token object for the given token string and service. Add the token to given UGI

Parameters:

ugi -

tokenStr -

tokenService -

Throws:

IOException

addServiceToToken

public static String addServiceToToken(String tokenStr,
                       String tokenService)
                                throws IOException

Add a given service to delegation token string.

Parameters:

tokenStr -

tokenService -

Returns:

Throws:

IOException

setZookeeperClientKerberosJaasConfig

public static void setZookeeperClientKerberosJaasConfig(String principal,
                                        String keyTabFile)
                                                 throws IOException

Dynamically sets up the JAAS configuration that uses kerberos

Parameters:

principal -

keyTabFile -

Throws:

IOException