All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type |
Method and Description |
void |
cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
cancelOperation(OperationHandle opHandle) |
void |
closeOperation(OperationHandle opHandle) |
void |
closeSession(SessionHandle sessionHandle) |
void |
createSessionWithSessionHandle(SessionHandle sessionHandle,
String username,
String password,
Map<String,String> configuration)
Used to restore session
|
OperationHandle |
executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay)
Execute statement on the server.
|
OperationHandle |
executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout)
Execute statement on the server with a timeout.
|
OperationHandle |
executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay)
Execute statement asynchronously on the server.
|
OperationHandle |
executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout)
Execute statement asynchronously on the server with a timeout.
|
RowSet |
fetchResults(OperationHandle opHandle) |
RowSet |
fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
OperationHandle |
getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
String |
getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
getDelegationTokenFromMetaStore(String owner) |
OperationHandle |
getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
org.apache.hadoop.security.UserGroupInformation |
getHttpUGI() |
GetInfoValue |
getInfo(SessionHandle sessionHandle,
GetInfoType getInfoType) |
OperationStatus |
getOperationStatus(OperationHandle opHandle,
boolean getProgressUpdate) |
OperationHandle |
getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
String |
getQueryId(TOperationHandle opHandle) |
TableSchema |
getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
org.apache.hadoop.security.UserGroupInformation |
getServiceUGI() |
HiveConf |
getSessionConf(SessionHandle sessionHandle) |
SessionManager |
getSessionManager() |
OperationHandle |
getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
getTypeInfo(SessionHandle sessionHandle) |
void |
init(HiveConf hiveConf)
Initialize the service.
|
SessionHandle |
openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
openSession(TProtocolVersion protocol,
String username,
String password,
Map<String,String> configuration)
|
SessionHandle |
openSession(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> configuration) |
SessionHandle |
openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
SessionHandle |
openSessionWithImpersonation(TProtocolVersion protocol,
String username,
String password,
Map<String,String> configuration,
String delegationToken)
|
SessionHandle |
openSessionWithImpersonation(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> configuration,
String delegationToken) |
void |
renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
setApplicationName(SessionHandle sh,
String value) |
void |
start()
Start the service.
|
void |
stop()
Stop the service.
|