org.apache.hive.service.cli.session

Class HiveSessionImplwithUGI

java.lang.Object

org.apache.hive.service.cli.session.HiveSessionImpl

org.apache.hive.service.cli.session.HiveSessionImplwithUGI

All Implemented Interfaces:

HiveSession, HiveSessionBase

public class HiveSessionImplwithUGI
extends HiveSessionImpl

HiveSessionImplwithUGI. HiveSession with connecting user's UGI and delegation token if required. Note: this object may be shared between threads in HS2.

Field Summary

Fields

Modifier and Type	Field and Description
static String	HS2TOKEN

Constructor Summary

Constructors

Constructor and Description
HiveSessionImplwithUGI(SessionHandle sessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, HiveConf hiveConf, String ipAddress, String delegationToken, List<String> forwardedAddresses)

Method Summary

Modifier and Type	Method and Description
void	cancelDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	close() Close the file systems for the session and remove it from the FileSystem cache.
String	getDelegationToken()
String	getDelegationToken(HiveAuthFactory authFactory, String owner, String renewer)
IMetaStoreClient	getMetaStoreClient()
protected HiveSession	getSession()
org.apache.hadoop.security.UserGroupInformation	getSessionUgi()
void	renewDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	setProxySession(HiveSession proxySession)
void	setSessionUGI(String owner)

Methods inherited from class org.apache.hive.service.cli.session.HiveSessionImpl

acquire, cancelOperation, closeExpiredOperations, closeOperation, executeStatement, executeStatement, executeStatementAsync, executeStatementAsync, fetchResults, getCatalogs, getColumns, getCreationTime, getCrossReference, getForwardedAddresses, getFunctions, getHiveConf, getInfo, getIpAddress, getLastAccessTime, getNoOperationTime, getOpenOperationCount, getOperationLogSessionDir, getPassword, getPrimaryKeys, getProtocolVersion, getResultSetMetadata, getSchemas, getSessionConf, getSessionHandle, getSessionHive, getSessionManager, getSessionState, getTables, getTableTypes, getTypeInfo, getUserName, isOperationLogEnabled, open, release, setApplicationName, setForwardedAddresses, setIpAddress, setOperationLogSessionDir, setOperationManager, setSessionManager, setUserName, submitBackgroundOperation

Methods inherited from class java.lang.Object

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

Field Detail

HS2TOKEN

public static final String HS2TOKEN

See Also:

Constant Field Values

Constructor Detail

HiveSessionImplwithUGI

public HiveSessionImplwithUGI(SessionHandle sessionHandle,
                              org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
                              String username,
                              String password,
                              HiveConf hiveConf,
                              String ipAddress,
                              String delegationToken,
                              List<String> forwardedAddresses)
                       throws HiveSQLException

Throws:

HiveSQLException

Method Detail

setSessionUGI

public void setSessionUGI(String owner)
                   throws HiveSQLException

Throws:

HiveSQLException

getSessionUgi

public org.apache.hadoop.security.UserGroupInformation getSessionUgi()

getDelegationToken

public String getDelegationToken()

close

public void close()
           throws HiveSQLException

Close the file systems for the session and remove it from the FileSystem cache. Cancel the session's delegation token and close the metastore connection

Specified by:

close in interface HiveSession

Overrides:

close in class HiveSessionImpl

Throws:

HiveSQLException

getMetaStoreClient

public IMetaStoreClient getMetaStoreClient()
                                    throws HiveSQLException

Specified by:

getMetaStoreClient in interface HiveSession

Overrides:

getMetaStoreClient in class HiveSessionImpl

Throws:

HiveSQLException

getSession

protected HiveSession getSession()

Overrides:

getSession in class HiveSessionImpl

setProxySession

public void setProxySession(HiveSession proxySession)

getDelegationToken

public String getDelegationToken(HiveAuthFactory authFactory,
                                 String owner,
                                 String renewer)
                          throws HiveSQLException

Specified by:

getDelegationToken in interface HiveSession

Overrides:

getDelegationToken in class HiveSessionImpl

Throws:

HiveSQLException

cancelDelegationToken

public void cancelDelegationToken(HiveAuthFactory authFactory,
                                  String tokenStr)
                           throws HiveSQLException

Specified by:

cancelDelegationToken in interface HiveSession

Overrides:

cancelDelegationToken in class HiveSessionImpl

Throws:

HiveSQLException

renewDelegationToken

public void renewDelegationToken(HiveAuthFactory authFactory,
                                 String tokenStr)
                          throws HiveSQLException

Specified by:

renewDelegationToken in interface HiveSession

Overrides:

renewDelegationToken in class HiveSessionImpl

Throws:

HiveSQLException