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(SessionHandle sessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion protocol, String username, String password, HiveConf serverConf, String ipAddress, List<String> forwardedAddresses)

Method Summary

Modifier and Type	Method and Description
protected void	acquire(boolean userAccess, boolean isOperation)
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	executeStatement(String statement, Map<String,String> confOverlay, long queryTimeout) execute operation handler
OperationHandle	executeStatementAsync(String statement, Map<String,String> confOverlay) execute operation handler
OperationHandle	executeStatementAsync(String statement, Map<String,String> confOverlay, long queryTimeout) 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
long	getCreationTime()
OperationHandle	getCrossReference(String primaryCatalog, String primarySchema, String primaryTable, String foreignCatalog, String foreignSchema, String foreignTable) getCrossReference operation handler
String	getDelegationToken(HiveAuthFactory authFactory, String owner, String renewer)
List<String>	getForwardedAddresses()
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()
int	getOpenOperationCount()
File	getOperationLogSessionDir() Get the session dir, which is the parent dir of operation logs
String	getPassword()
OperationHandle	getPrimaryKeys(String catalog, String schema, String table) getPrimaryKeys operation handler
org.apache.hive.service.rpc.thrift.TProtocolVersion	getProtocolVersion()
TableSchema	getResultSetMetadata(OperationHandle opHandle)
OperationHandle	getSchemas(String catalogName, String schemaName) getSchemas operation handler
protected HiveSession	getSession()
HiveConf	getSessionConf()
SessionHandle	getSessionHandle()
Hive	getSessionHive()
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()
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, boolean isOperation) 1.
void	renewDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	setApplicationName(String value)
void	setForwardedAddresses(List<String> forwardedAddresses)
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)
Future<?>	submitBackgroundOperation(Runnable work)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveSessionImpl

public HiveSessionImpl(SessionHandle sessionHandle,
                       org.apache.hive.service.rpc.thrift.TProtocolVersion protocol,
                       String username,
                       String password,
                       HiveConf serverConf,
                       String ipAddress,
                       List<String> forwardedAddresses)

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 org.apache.hive.service.rpc.thrift.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,
                       boolean isOperation)

release

protected void release(boolean userAccess,
                       boolean isOperation)

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

getPassword

public String getPassword()

Specified by:

getPassword in interface HiveSessionBase

getHiveConf

public HiveConf getHiveConf()

Specified by:

getHiveConf in interface HiveSessionBase

getSessionHive

public Hive getSessionHive()

Specified by:

getSessionHive in interface HiveSession

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

getSessionConf

public HiveConf getSessionConf()
                        throws HiveSQLException

Specified by:

getSessionConf 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

executeStatement

public OperationHandle executeStatement(String statement,
                                        Map<String,String> confOverlay,
                                        long queryTimeout)
                                 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

executeStatementAsync

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

Description copied from interface: HiveSession

execute operation handler

Specified by:

executeStatementAsync in interface HiveSession

Returns:

Throws:

HiveSQLException

submitBackgroundOperation

public Future<?> submitBackgroundOperation(Runnable work)

Specified by:

submitBackgroundOperation in interface HiveSession

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

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime 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()

getOpenOperationCount

public int getOpenOperationCount()

Specified by:

getOpenOperationCount in interface HiveSessionBase

getIpAddress

public String getIpAddress()

Specified by:

getIpAddress in interface HiveSessionBase

setIpAddress

public void setIpAddress(String ipAddress)

Specified by:

setIpAddress in interface HiveSessionBase

getForwardedAddresses

public List<String> getForwardedAddresses()

Specified by:

getForwardedAddresses in interface HiveSessionBase

setForwardedAddresses

public void setForwardedAddresses(List<String> forwardedAddresses)

Specified by:

setForwardedAddresses 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

getPrimaryKeys

public OperationHandle getPrimaryKeys(String catalog,
                                      String schema,
                                      String table)
                               throws HiveSQLException

Description copied from interface: HiveSession

getPrimaryKeys operation handler

Specified by:

getPrimaryKeys in interface HiveSession

Returns:

Throws:

HiveSQLException

getCrossReference

public OperationHandle getCrossReference(String primaryCatalog,
                                         String primarySchema,
                                         String primaryTable,
                                         String foreignCatalog,
                                         String foreignSchema,
                                         String foreignTable)
                                  throws HiveSQLException

Description copied from interface: HiveSession

getCrossReference operation handler

Specified by:

getCrossReference in interface HiveSession

Returns:

Throws:

HiveSQLException

setApplicationName

public void setApplicationName(String value)

Specified by:

setApplicationName in interface HiveSession