public interface HiveSession extends HiveSessionBase
| 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 |
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
|
GetInfoValue |
getInfo(GetInfoType getInfoType)
getInfo operation handler
|
IMetaStoreClient |
getMetaStoreClient() |
long |
getNoOperationTime() |
TableSchema |
getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
getSchemas(String catalogName,
String schemaName)
getSchemas operation handler
|
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) |
getHiveConf, getIpAddress, getLastAccessTime, getOperationLogSessionDir, getPassword, getProtocolVersion, getSessionHandle, getSessionManager, getSessionState, getUsername, getUserName, isOperationLogEnabled, setIpAddress, setOperationLogSessionDir, setOperationManager, setSessionManager, setUserNameIMetaStoreClient getMetaStoreClient() throws HiveSQLException
HiveSQLExceptionGetInfoValue getInfo(GetInfoType getInfoType) throws HiveSQLException
getInfoType - HiveSQLExceptionOperationHandle executeStatement(String statement, Map<String,String> confOverlay) throws HiveSQLException
statement - confOverlay - HiveSQLExceptionOperationHandle executeStatementAsync(String statement, Map<String,String> confOverlay) throws HiveSQLException
statement - confOverlay - HiveSQLExceptionOperationHandle getTypeInfo() throws HiveSQLException
HiveSQLExceptionOperationHandle getCatalogs() throws HiveSQLException
HiveSQLExceptionOperationHandle getSchemas(String catalogName, String schemaName) throws HiveSQLException
catalogName - schemaName - HiveSQLExceptionOperationHandle getTables(String catalogName, String schemaName, String tableName, List<String> tableTypes) throws HiveSQLException
catalogName - schemaName - tableName - tableTypes - HiveSQLExceptionOperationHandle getTableTypes() throws HiveSQLException
HiveSQLExceptionOperationHandle getColumns(String catalogName, String schemaName, String tableName, String columnName) throws HiveSQLException
catalogName - schemaName - tableName - columnName - HiveSQLExceptionOperationHandle getFunctions(String catalogName, String schemaName, String functionName) throws HiveSQLException
catalogName - schemaName - functionName - HiveSQLExceptionvoid close()
throws HiveSQLException
HiveSQLExceptionvoid cancelOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLExceptionvoid closeOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLExceptionTableSchema getResultSetMetadata(OperationHandle opHandle) throws HiveSQLException
HiveSQLExceptionRowSet fetchResults(OperationHandle opHandle, FetchOrientation orientation, long maxRows, FetchType fetchType) throws HiveSQLException
HiveSQLExceptionString getDelegationToken(HiveAuthFactory authFactory, String owner, String renewer) throws HiveSQLException
HiveSQLExceptionvoid cancelDelegationToken(HiveAuthFactory authFactory, String tokenStr) throws HiveSQLException
HiveSQLExceptionvoid renewDelegationToken(HiveAuthFactory authFactory, String tokenStr) throws HiveSQLException
HiveSQLExceptionvoid closeExpiredOperations()
long getNoOperationTime()
Copyright © 2017 The Apache Software Foundation. All rights reserved.