org.apache.hive.service.cli.session

Interface HiveSession

All Superinterfaces:

HiveSessionBase

All Known Implementing Classes:

HiveSessionImpl, HiveSessionImplwithUGI

public interface HiveSession
extends HiveSessionBase

Method Summary

Modifier and Type	Method and Description
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
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)
OperationHandle	getFunctions(String catalogName, String schemaName, String functionName) getFunctions operation handler
GetInfoValue	getInfo(GetInfoType getInfoType) getInfo operation handler
IMetaStoreClient	getMetaStoreClient()
long	getNoOperationTime()
OperationHandle	getPrimaryKeys(String catalog, String schema, String table) getPrimaryKeys operation handler
TableSchema	getResultSetMetadata(OperationHandle opHandle)
OperationHandle	getSchemas(String catalogName, String schemaName) getSchemas operation handler
HiveConf	getSessionConf()
Hive	getSessionHive()
OperationHandle	getTables(String catalogName, String schemaName, String tableName, List<String> tableTypes) getTables operation handler
OperationHandle	getTableTypes() getTableTypes operation handler
OperationHandle	getTypeInfo() getTypeInfo operation handler
void	open(Map<String,String> sessionConfMap)
void	renewDelegationToken(HiveAuthFactory authFactory, String tokenStr)
void	setApplicationName(String value)
Future<?>	submitBackgroundOperation(Runnable work)

Methods inherited from interface org.apache.hive.service.cli.session.HiveSessionBase

getCreationTime, getForwardedAddresses, getHiveConf, getIpAddress, getLastAccessTime, getOpenOperationCount, getOperationLogSessionDir, getPassword, getProtocolVersion, getSessionHandle, getSessionManager, getSessionState, getUserName, isOperationLogEnabled, setForwardedAddresses, setIpAddress, setOperationLogSessionDir, setOperationManager, setSessionManager, setUserName

Method Detail

open

void open(Map<String,String> sessionConfMap)
   throws Exception

Throws:

Exception

getMetaStoreClient

IMetaStoreClient getMetaStoreClient()
                             throws HiveSQLException

Throws:

HiveSQLException

getSessionHive

Hive getSessionHive()
             throws HiveSQLException

Throws:

HiveSQLException

getInfo

GetInfoValue getInfo(GetInfoType getInfoType)
              throws HiveSQLException

getInfo operation handler

Parameters:

getInfoType -

Returns:

Throws:

HiveSQLException

executeStatement

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

execute operation handler

Parameters:

statement -

confOverlay -

Returns:

Throws:

HiveSQLException

executeStatement

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

execute operation handler

Parameters:

statement -

confOverlay -

queryTimeout -

Returns:

Throws:

HiveSQLException

executeStatementAsync

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

execute operation handler

Parameters:

statement -

confOverlay -

Returns:

Throws:

HiveSQLException

executeStatementAsync

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

execute operation handler

Parameters:

statement -

confOverlay -

queryTimeout -

Returns:

Throws:

HiveSQLException

getTypeInfo

OperationHandle getTypeInfo()
                     throws HiveSQLException

getTypeInfo operation handler

Returns:

Throws:

HiveSQLException

getCatalogs

OperationHandle getCatalogs()
                     throws HiveSQLException

getCatalogs operation handler

Returns:

Throws:

HiveSQLException

getSchemas

OperationHandle getSchemas(String catalogName,
                           String schemaName)
                    throws HiveSQLException

getSchemas operation handler

Parameters:

catalogName -

schemaName -

Returns:

Throws:

HiveSQLException

getTables

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

getTables operation handler

Parameters:

catalogName -

schemaName -

tableName -

tableTypes -

Returns:

Throws:

HiveSQLException

getTableTypes

OperationHandle getTableTypes()
                       throws HiveSQLException

getTableTypes operation handler

Returns:

Throws:

HiveSQLException

getColumns

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

getColumns operation handler

Parameters:

catalogName -

schemaName -

tableName -

columnName -

Returns:

Throws:

HiveSQLException

getFunctions

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

getFunctions operation handler

Parameters:

catalogName -

schemaName -

functionName -

Returns:

Throws:

HiveSQLException

getPrimaryKeys

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

getPrimaryKeys operation handler

Parameters:

catalog -

schema -

table -

Returns:

Throws:

HiveSQLException

getCrossReference

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

getCrossReference operation handler

Parameters:

primaryCatalog -

primarySchema -

primaryTable -

foreignCatalog -

foreignSchema -

foreignTable -

Returns:

Throws:

HiveSQLException

getSessionConf

HiveConf getSessionConf()
                 throws HiveSQLException

Returns:

Throws:

HiveSQLException

close

void close()
    throws HiveSQLException

close the session

Throws:

HiveSQLException

cancelOperation

void cancelOperation(OperationHandle opHandle)
              throws HiveSQLException

Throws:

HiveSQLException

closeOperation

void closeOperation(OperationHandle opHandle)
             throws HiveSQLException

Throws:

HiveSQLException

getResultSetMetadata

TableSchema getResultSetMetadata(OperationHandle opHandle)
                          throws HiveSQLException

Throws:

HiveSQLException

fetchResults

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

Throws:

HiveSQLException

getDelegationToken

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

Throws:

HiveSQLException

cancelDelegationToken

void cancelDelegationToken(HiveAuthFactory authFactory,
                           String tokenStr)
                    throws HiveSQLException

Throws:

HiveSQLException

renewDelegationToken

void renewDelegationToken(HiveAuthFactory authFactory,
                          String tokenStr)
                   throws HiveSQLException

Throws:

HiveSQLException

closeExpiredOperations

void closeExpiredOperations()

getNoOperationTime

long getNoOperationTime()

submitBackgroundOperation

Future<?> submitBackgroundOperation(Runnable work)

setApplicationName

void setApplicationName(String value)