org.apache.hive.service.cli.session

Class HiveSessionImpl

java.lang.Object

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

All Implemented Interfaces:

HiveSession, HiveSessionBase

Direct Known Subclasses:

HiveSessionImplwithUGI

public class HiveSessionImpl
extends Object
implements HiveSession

HiveSession

Constructor Summary

Constructors

Constructor and Description
HiveSessionImpl(TProtocolVersion protocol, String username, String password, HiveConf serverhiveConf, String ipAddress)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	acquire(boolean userAccess)
void	cancelDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	cancelOperation(OperationHandle opHandle)
void	close() close the session
void	closeExpiredOperations()
void	closeOperation(OperationHandle opHandle)
OperationHandle	executeStatement(String statement, Map<String,String> confOverlay) execute operation handler
OperationHandle	executeStatementAsync(String statement, Map<String,String> confOverlay) execute operation handler
RowSet	fetchResults(OperationHandle opHandle, FetchOrientation orientation, long maxRows, FetchType fetchType)
OperationHandle	getCatalogs() getCatalogs operation handler
OperationHandle	getColumns(String catalogName, String schemaName, String tableName, String columnName) getColumns operation handler
String	getDelegationToken(HiveAuthFactory authFactory, String owner, String renewer)
OperationHandle	getFunctions(String catalogName, String schemaName, String functionName) getFunctions operation handler
HiveConf	getHiveConf()
GetInfoValue	getInfo(GetInfoType getInfoType) getInfo operation handler
String	getIpAddress()
long	getLastAccessTime()
IMetaStoreClient	getMetaStoreClient()
long	getNoOperationTime()
File	getOperationLogSessionDir() Get the session dir, which is the parent dir of operation logs
String	getPassword()
TProtocolVersion	getProtocolVersion()
TableSchema	getResultSetMetadata(OperationHandle opHandle)
OperationHandle	getSchemas(String catalogName, String schemaName) getSchemas operation handler
protected HiveSession	getSession()
SessionHandle	getSessionHandle()
SessionManager	getSessionManager() Get the session manager for the session
SessionState	getSessionState()
OperationHandle	getTables(String catalogName, String schemaName, String tableName, List<String> tableTypes) getTables operation handler
OperationHandle	getTableTypes() getTableTypes operation handler
OperationHandle	getTypeInfo() getTypeInfo operation handler
String	getUsername()
String	getUserName()
boolean	isOperationLogEnabled() Check whether operation logging is enabled and session dir is created successfully
void	open(Map<String,String> sessionConfMap)
protected void	release(boolean userAccess) 1.
void	renewDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	setIpAddress(String ipAddress)
void	setOperationLogSessionDir(File operationLogRootDir) Set the session dir, which is the parent dir of operation logs
void	setOperationManager(OperationManager operationManager) Set operation manager for the session
void	setSessionManager(SessionManager sessionManager) Set the session manager for the session
void	setUserName(String userName)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveSessionImpl

public HiveSessionImpl(TProtocolVersion protocol,
               String username,
               String password,
               HiveConf serverhiveConf,
               String ipAddress)

Method Detail

open

public void open(Map<String,String> sessionConfMap)
          throws HiveSQLException

Specified by:

open in interface HiveSession

Throws:

HiveSQLException

setOperationLogSessionDir

public void setOperationLogSessionDir(File operationLogRootDir)

Description copied from interface: HiveSessionBase

Set the session dir, which is the parent dir of operation logs

Specified by:

setOperationLogSessionDir in interface HiveSessionBase

Parameters:

operationLogRootDir - the parent dir of the session dir

isOperationLogEnabled

public boolean isOperationLogEnabled()

Description copied from interface: HiveSessionBase

Check whether operation logging is enabled and session dir is created successfully

Specified by:

isOperationLogEnabled in interface HiveSessionBase

getOperationLogSessionDir

public File getOperationLogSessionDir()

Description copied from interface: HiveSessionBase

Get the session dir, which is the parent dir of operation logs

Specified by:

getOperationLogSessionDir in interface HiveSessionBase

Returns:

a file representing the parent directory of operation logs

getProtocolVersion

public TProtocolVersion getProtocolVersion()

Specified by:

getProtocolVersion in interface HiveSessionBase

getSessionManager

public SessionManager getSessionManager()

Description copied from interface: HiveSessionBase

Get the session manager for the session

Specified by:

getSessionManager in interface HiveSessionBase

setSessionManager

public void setSessionManager(SessionManager sessionManager)

Description copied from interface: HiveSessionBase

Set the session manager for the session

Specified by:

setSessionManager in interface HiveSessionBase

setOperationManager

public void setOperationManager(OperationManager operationManager)

Description copied from interface: HiveSessionBase

Set operation manager for the session

Specified by:

setOperationManager in interface HiveSessionBase

acquire

protected void acquire(boolean userAccess)

release

protected void release(boolean userAccess)

1. We'll remove the ThreadLocal SessionState as this thread might now serve other requests. 2. We'll cache the ThreadLocal RawStore object for this background thread for an orderly cleanup when this thread is garbage collected later.

See Also:

ThreadWithGarbageCleanup.finalize()

getSessionHandle

public SessionHandle getSessionHandle()

Specified by:

getSessionHandle in interface HiveSessionBase

getUsername

public String getUsername()

Specified by:

getUsername in interface HiveSessionBase

getPassword

public String getPassword()

Specified by:

getPassword in interface HiveSessionBase

getHiveConf

public HiveConf getHiveConf()

Specified by:

getHiveConf in interface HiveSessionBase

getMetaStoreClient

public IMetaStoreClient getMetaStoreClient()
                                    throws HiveSQLException

Specified by:

getMetaStoreClient in interface HiveSession

Throws:

HiveSQLException

getInfo

public GetInfoValue getInfo(GetInfoType getInfoType)
                     throws HiveSQLException

Description copied from interface: HiveSession

getInfo operation handler

Specified by:

getInfo in interface HiveSession

Returns:

Throws:

HiveSQLException

executeStatement

public OperationHandle executeStatement(String statement,
                               Map<String,String> confOverlay)
                                 throws HiveSQLException

Description copied from interface: HiveSession

execute operation handler

Specified by:

executeStatement in interface HiveSession

Returns:

Throws:

HiveSQLException

executeStatementAsync

public OperationHandle executeStatementAsync(String statement,
                                    Map<String,String> confOverlay)
                                      throws HiveSQLException

Description copied from interface: HiveSession

execute operation handler

Specified by:

executeStatementAsync in interface HiveSession

Returns:

Throws:

HiveSQLException

getTypeInfo

public OperationHandle getTypeInfo()
                            throws HiveSQLException

Description copied from interface: HiveSession

getTypeInfo operation handler

Specified by:

getTypeInfo in interface HiveSession

Returns:

Throws:

HiveSQLException

getCatalogs

public OperationHandle getCatalogs()
                            throws HiveSQLException

Description copied from interface: HiveSession

getCatalogs operation handler

Specified by:

getCatalogs in interface HiveSession

Returns:

Throws:

HiveSQLException

getSchemas

public OperationHandle getSchemas(String catalogName,
                         String schemaName)
                           throws HiveSQLException

Description copied from interface: HiveSession

getSchemas operation handler

Specified by:

getSchemas in interface HiveSession

Returns:

Throws:

HiveSQLException

getTables

public OperationHandle getTables(String catalogName,
                        String schemaName,
                        String tableName,
                        List<String> tableTypes)
                          throws HiveSQLException

Description copied from interface: HiveSession

getTables operation handler

Specified by:

getTables in interface HiveSession

Returns:

Throws:

HiveSQLException

getTableTypes

public OperationHandle getTableTypes()
                              throws HiveSQLException

Description copied from interface: HiveSession

getTableTypes operation handler

Specified by:

getTableTypes in interface HiveSession

Returns:

Throws:

HiveSQLException

getColumns

public OperationHandle getColumns(String catalogName,
                         String schemaName,
                         String tableName,
                         String columnName)
                           throws HiveSQLException

Description copied from interface: HiveSession

getColumns operation handler

Specified by:

getColumns in interface HiveSession

Returns:

Throws:

HiveSQLException

getFunctions

public OperationHandle getFunctions(String catalogName,
                           String schemaName,
                           String functionName)
                             throws HiveSQLException

Description copied from interface: HiveSession

getFunctions operation handler

Specified by:

getFunctions in interface HiveSession

Returns:

Throws:

HiveSQLException

close

public void close()
           throws HiveSQLException

Description copied from interface: HiveSession

close the session

Specified by:

close in interface HiveSession

Throws:

HiveSQLException

getSessionState

public SessionState getSessionState()

Specified by:

getSessionState in interface HiveSessionBase

getUserName

public String getUserName()

Specified by:

getUserName in interface HiveSessionBase

setUserName

public void setUserName(String userName)

Specified by:

setUserName in interface HiveSessionBase

getLastAccessTime

public long getLastAccessTime()

Specified by:

getLastAccessTime in interface HiveSessionBase

closeExpiredOperations

public void closeExpiredOperations()

Specified by:

closeExpiredOperations in interface HiveSession

getNoOperationTime

public long getNoOperationTime()

Specified by:

getNoOperationTime in interface HiveSession

cancelOperation

public void cancelOperation(OperationHandle opHandle)
                     throws HiveSQLException

Specified by:

cancelOperation in interface HiveSession

Throws:

HiveSQLException

closeOperation

public void closeOperation(OperationHandle opHandle)
                    throws HiveSQLException

Specified by:

closeOperation in interface HiveSession

Throws:

HiveSQLException

getResultSetMetadata

public TableSchema getResultSetMetadata(OperationHandle opHandle)
                                 throws HiveSQLException

Specified by:

getResultSetMetadata in interface HiveSession

Throws:

HiveSQLException

fetchResults

public RowSet fetchResults(OperationHandle opHandle,
                  FetchOrientation orientation,
                  long maxRows,
                  FetchType fetchType)
                    throws HiveSQLException

Specified by:

fetchResults in interface HiveSession

Throws:

HiveSQLException

getSession

protected HiveSession getSession()

getIpAddress

public String getIpAddress()

Specified by:

getIpAddress in interface HiveSessionBase

setIpAddress

public void setIpAddress(String ipAddress)

Specified by:

setIpAddress in interface HiveSessionBase

getDelegationToken

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

Specified by:

getDelegationToken in interface HiveSession

Throws:

HiveSQLException

cancelDelegationToken

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

Specified by:

cancelDelegationToken in interface HiveSession

Throws:

HiveSQLException

renewDelegationToken

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

Specified by:

renewDelegationToken in interface HiveSession

Throws:

HiveSQLException