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, setUserName
IMetaStoreClient getMetaStoreClient() throws HiveSQLException
HiveSQLException
GetInfoValue getInfo(GetInfoType getInfoType) throws HiveSQLException
getInfoType
- HiveSQLException
OperationHandle executeStatement(String statement, Map<String,String> confOverlay) throws HiveSQLException
statement
- confOverlay
- HiveSQLException
OperationHandle executeStatementAsync(String statement, Map<String,String> confOverlay) throws HiveSQLException
statement
- confOverlay
- HiveSQLException
OperationHandle getTypeInfo() throws HiveSQLException
HiveSQLException
OperationHandle getCatalogs() throws HiveSQLException
HiveSQLException
OperationHandle getSchemas(String catalogName, String schemaName) throws HiveSQLException
catalogName
- schemaName
- HiveSQLException
OperationHandle getTables(String catalogName, String schemaName, String tableName, List<String> tableTypes) throws HiveSQLException
catalogName
- schemaName
- tableName
- tableTypes
- HiveSQLException
OperationHandle getTableTypes() throws HiveSQLException
HiveSQLException
OperationHandle getColumns(String catalogName, String schemaName, String tableName, String columnName) throws HiveSQLException
catalogName
- schemaName
- tableName
- columnName
- HiveSQLException
OperationHandle getFunctions(String catalogName, String schemaName, String functionName) throws HiveSQLException
catalogName
- schemaName
- functionName
- HiveSQLException
void close() throws HiveSQLException
HiveSQLException
void cancelOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
void closeOperation(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
TableSchema getResultSetMetadata(OperationHandle opHandle) throws HiveSQLException
HiveSQLException
RowSet fetchResults(OperationHandle opHandle, FetchOrientation orientation, long maxRows, FetchType fetchType) throws HiveSQLException
HiveSQLException
String getDelegationToken(HiveAuthFactory authFactory, String owner, String renewer) throws HiveSQLException
HiveSQLException
void cancelDelegationToken(HiveAuthFactory authFactory, String tokenStr) throws HiveSQLException
HiveSQLException
void renewDelegationToken(HiveAuthFactory authFactory, String tokenStr) throws HiveSQLException
HiveSQLException
void closeExpiredOperations()
long getNoOperationTime()
Copyright © 2017 The Apache Software Foundation. All rights reserved.