Modifier and Type | Method and Description |
---|---|
void |
HiveAuthFactory.cancelDelegationToken(String delegationToken) |
String |
HiveAuthFactory.getDelegationToken(String owner,
String renewer,
String remoteAddr) |
String |
HiveAuthFactory.getUserFromToken(String delegationToken) |
void |
HiveAuthFactory.renewDelegationToken(String delegationToken) |
String |
HiveAuthFactory.verifyDelegationToken(String delegationToken) |
static void |
HiveAuthFactory.verifyProxyAccess(String realUser,
String proxyUser,
String ipAddress,
HiveConf hiveConf) |
Modifier and Type | Method and Description |
---|---|
HiveSQLException |
OperationStatus.getOperationException() |
Modifier and Type | Method and Description |
---|---|
void |
ICLIService.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
EmbeddedCLIServiceClient.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
abstract void |
CLIServiceClient.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
CLIService.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
ICLIService.cancelOperation(OperationHandle opHandle) |
void |
EmbeddedCLIServiceClient.cancelOperation(OperationHandle opHandle) |
void |
CLIService.cancelOperation(OperationHandle opHandle) |
void |
ICLIService.closeOperation(OperationHandle opHandle) |
void |
EmbeddedCLIServiceClient.closeOperation(OperationHandle opHandle) |
void |
CLIService.closeOperation(OperationHandle opHandle) |
void |
ICLIService.closeSession(SessionHandle sessionHandle) |
void |
EmbeddedCLIServiceClient.closeSession(SessionHandle sessionHandle) |
void |
CLIService.closeSession(SessionHandle sessionHandle) |
void |
CLIService.createSessionWithSessionHandle(SessionHandle sessionHandle,
String username,
String password,
Map<String,String> configuration)
Used to restore session
|
OperationHandle |
ICLIService.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
EmbeddedCLIServiceClient.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
CLIService.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay)
Execute statement on the server.
|
OperationHandle |
ICLIService.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
EmbeddedCLIServiceClient.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
CLIService.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout)
Execute statement on the server with a timeout.
|
OperationHandle |
ICLIService.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
EmbeddedCLIServiceClient.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
CLIService.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay)
Execute statement asynchronously on the server.
|
OperationHandle |
ICLIService.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
EmbeddedCLIServiceClient.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
CLIService.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout)
Execute statement asynchronously on the server with a timeout.
|
RowSet |
ICLIService.fetchResults(OperationHandle opHandle) |
RowSet |
CLIServiceClient.fetchResults(OperationHandle opHandle) |
RowSet |
CLIService.fetchResults(OperationHandle opHandle) |
RowSet |
ICLIService.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
RowSet |
EmbeddedCLIServiceClient.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
RowSet |
CLIService.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
OperationHandle |
ICLIService.getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
EmbeddedCLIServiceClient.getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
CLIService.getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
ICLIService.getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
EmbeddedCLIServiceClient.getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
CLIService.getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
ICLIService.getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
OperationHandle |
EmbeddedCLIServiceClient.getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
OperationHandle |
CLIService.getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
String |
ICLIService.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
EmbeddedCLIServiceClient.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
abstract String |
CLIServiceClient.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
CLIService.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
CLIService.getDelegationTokenFromMetaStore(String owner) |
OperationHandle |
ICLIService.getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
OperationHandle |
EmbeddedCLIServiceClient.getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
OperationHandle |
CLIService.getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
GetInfoValue |
ICLIService.getInfo(SessionHandle sessionHandle,
GetInfoType infoType) |
GetInfoValue |
EmbeddedCLIServiceClient.getInfo(SessionHandle sessionHandle,
GetInfoType getInfoType) |
GetInfoValue |
CLIService.getInfo(SessionHandle sessionHandle,
GetInfoType getInfoType) |
OperationStatus |
ICLIService.getOperationStatus(OperationHandle opHandle) |
OperationStatus |
EmbeddedCLIServiceClient.getOperationStatus(OperationHandle opHandle) |
OperationStatus |
CLIService.getOperationStatus(OperationHandle opHandle) |
OperationHandle |
ICLIService.getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
OperationHandle |
EmbeddedCLIServiceClient.getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
OperationHandle |
CLIService.getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
TableSchema |
ICLIService.getResultSetMetadata(OperationHandle opHandle) |
TableSchema |
EmbeddedCLIServiceClient.getResultSetMetadata(OperationHandle opHandle) |
TableSchema |
CLIService.getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
ICLIService.getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
OperationHandle |
EmbeddedCLIServiceClient.getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
OperationHandle |
CLIService.getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
OperationHandle |
ICLIService.getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
EmbeddedCLIServiceClient.getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
CLIService.getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
ICLIService.getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
EmbeddedCLIServiceClient.getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
CLIService.getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
ICLIService.getTypeInfo(SessionHandle sessionHandle) |
OperationHandle |
EmbeddedCLIServiceClient.getTypeInfo(SessionHandle sessionHandle) |
OperationHandle |
CLIService.getTypeInfo(SessionHandle sessionHandle) |
SessionHandle |
CLIServiceClient.openSession(String username,
String password) |
SessionHandle |
ICLIService.openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
EmbeddedCLIServiceClient.openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
CLIService.openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
CLIService.openSession(TProtocolVersion protocol,
String username,
String password,
Map<String,String> configuration)
|
SessionHandle |
CLIService.openSession(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> configuration) |
SessionHandle |
ICLIService.openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
SessionHandle |
EmbeddedCLIServiceClient.openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
SessionHandle |
CLIService.openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
SessionHandle |
CLIService.openSessionWithImpersonation(TProtocolVersion protocol,
String username,
String password,
Map<String,String> configuration,
String delegationToken)
|
SessionHandle |
CLIService.openSessionWithImpersonation(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> configuration,
String delegationToken) |
void |
ICLIService.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
EmbeddedCLIServiceClient.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
abstract void |
CLIServiceClient.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
CLIService.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
OperationState.validateTransition(OperationState newState) |
static void |
OperationState.validateTransition(OperationState oldState,
OperationState newState) |
Constructor and Description |
---|
OperationStatus(OperationState state,
String taskStatus,
long operationStarted,
long operationCompleted,
HiveSQLException operationException) |
Modifier and Type | Field and Description |
---|---|
protected HiveSQLException |
Operation.operationException |
Modifier and Type | Method and Description |
---|---|
protected HiveSQLException |
Operation.toSQLException(String prefix,
CommandProcessorResponse response) |
Modifier and Type | Method and Description |
---|---|
protected void |
Operation.setOperationException(HiveSQLException operationException) |
Modifier and Type | Method and Description |
---|---|
protected void |
Operation.assertState(List<OperationState> states) |
protected void |
MetadataOperation.authorizeMetaGets(HiveOperationType opType,
List<HivePrivilegeObject> inpObjs) |
protected void |
MetadataOperation.authorizeMetaGets(HiveOperationType opType,
List<HivePrivilegeObject> inpObjs,
String cmdString) |
void |
SQLOperation.cancel(OperationState stateAfterCancel) |
abstract void |
Operation.cancel(OperationState stateAfterCancel) |
void |
MetadataOperation.cancel(OperationState stateAfterCancel) |
void |
HiveCommandOperation.cancel(OperationState stateAfterCancel) |
void |
OperationManager.cancelOperation(OperationHandle opHandle)
Cancel the running operation unless it is already in a terminal state
|
void |
SQLOperation.close() |
abstract void |
Operation.close() |
void |
MetadataOperation.close() |
void |
HiveCommandOperation.close() |
void |
OperationManager.closeOperation(OperationHandle opHandle) |
RowSet |
Operation.getNextRowSet() |
RowSet |
SQLOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
abstract RowSet |
Operation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
HiveCommandOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetTypeInfoOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetTableTypesOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetTablesOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetSchemasOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetPrimaryKeysOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetFunctionsOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetCrossReferenceOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetColumnsOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
RowSet |
GetCatalogsOperation.getNextRowSet(FetchOrientation orientation,
long maxRows) |
Operation |
OperationManager.getOperation(OperationHandle operationHandle) |
RowSet |
OperationManager.getOperationLogRowSet(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
HiveConf hConf) |
RowSet |
OperationManager.getOperationNextRowSet(OperationHandle opHandle) |
RowSet |
OperationManager.getOperationNextRowSet(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows) |
TableSchema |
OperationManager.getOperationResultSetSchema(OperationHandle opHandle) |
OperationStatus |
OperationManager.getOperationStatus(OperationHandle opHandle) |
TableSchema |
SQLOperation.getResultSetSchema() |
abstract TableSchema |
Operation.getResultSetSchema() |
TableSchema |
HiveCommandOperation.getResultSetSchema() |
TableSchema |
GetTypeInfoOperation.getResultSetSchema() |
TableSchema |
GetTableTypesOperation.getResultSetSchema() |
TableSchema |
GetTablesOperation.getResultSetSchema() |
TableSchema |
GetSchemasOperation.getResultSetSchema() |
TableSchema |
GetPrimaryKeysOperation.getResultSetSchema() |
TableSchema |
GetFunctionsOperation.getResultSetSchema() |
TableSchema |
GetCrossReferenceOperation.getResultSetSchema() |
TableSchema |
GetColumnsOperation.getResultSetSchema() |
TableSchema |
GetCatalogsOperation.getResultSetSchema() |
String |
SQLOperation.getTaskStatus() |
String |
Operation.getTaskStatus() |
ExecuteStatementOperation |
OperationManager.newExecuteStatementOperation(HiveSession parentSession,
String statement,
Map<String,String> confOverlay,
boolean runAsync,
long queryTimeout) |
static ExecuteStatementOperation |
ExecuteStatementOperation.newExecuteStatementOperation(HiveSession parentSession,
String statement,
Map<String,String> confOverlay,
boolean runAsync,
long queryTimeout) |
void |
SQLOperation.prepare(QueryState queryState)
Compile the query and extract metadata
|
void |
Operation.run() |
void |
SQLOperation.runInternal() |
protected abstract void |
Operation.runInternal()
Implemented by subclass of Operation class to execute specific behaviors.
|
void |
HiveCommandOperation.runInternal() |
void |
GetTypeInfoOperation.runInternal() |
void |
GetTableTypesOperation.runInternal() |
void |
GetTablesOperation.runInternal() |
void |
GetSchemasOperation.runInternal() |
void |
GetPrimaryKeysOperation.runInternal() |
void |
GetFunctionsOperation.runInternal() |
void |
GetCrossReferenceOperation.runInternal() |
void |
GetColumnsOperation.runInternal() |
void |
GetCatalogsOperation.runInternal() |
protected OperationState |
Operation.setState(OperationState newState) |
protected void |
Operation.validateDefaultFetchOrientation(FetchOrientation orientation)
Verify if the given fetch orientation is part of the default orientation types.
|
protected void |
Operation.validateFetchOrientation(FetchOrientation orientation,
EnumSet<FetchOrientation> supportedOrientations)
Verify if the given fetch orientation is part of the supported orientation types.
|
Constructor and Description |
---|
SQLOperationDisplay(SQLOperation sqlOperation) |
Modifier and Type | Method and Description |
---|---|
void |
HiveSessionImplwithUGI.cancelDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSessionImpl.cancelDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSession.cancelDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSessionImpl.cancelOperation(OperationHandle opHandle) |
void |
HiveSession.cancelOperation(OperationHandle opHandle) |
void |
HiveSessionImplwithUGI.close()
Close the file systems for the session and remove it from the FileSystem cache.
|
void |
HiveSessionImpl.close() |
void |
HiveSession.close()
close the session
|
void |
HiveSessionImpl.closeOperation(OperationHandle opHandle) |
void |
HiveSession.closeOperation(OperationHandle opHandle) |
void |
SessionManager.closeSession(SessionHandle sessionHandle) |
HiveSession |
SessionManager.createSession(SessionHandle sessionHandle,
TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> sessionConf,
boolean withImpersonation,
String delegationToken) |
OperationHandle |
HiveSessionImpl.executeStatement(String statement,
Map<String,String> confOverlay) |
OperationHandle |
HiveSession.executeStatement(String statement,
Map<String,String> confOverlay)
execute operation handler
|
OperationHandle |
HiveSessionImpl.executeStatement(String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
HiveSession.executeStatement(String statement,
Map<String,String> confOverlay,
long queryTimeout)
execute operation handler
|
OperationHandle |
HiveSessionImpl.executeStatementAsync(String statement,
Map<String,String> confOverlay) |
OperationHandle |
HiveSession.executeStatementAsync(String statement,
Map<String,String> confOverlay)
execute operation handler
|
OperationHandle |
HiveSessionImpl.executeStatementAsync(String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
HiveSession.executeStatementAsync(String statement,
Map<String,String> confOverlay,
long queryTimeout)
execute operation handler
|
RowSet |
HiveSessionImpl.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
RowSet |
HiveSession.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
OperationHandle |
HiveSessionImpl.getCatalogs() |
OperationHandle |
HiveSession.getCatalogs()
getCatalogs operation handler
|
OperationHandle |
HiveSessionImpl.getColumns(String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
HiveSession.getColumns(String catalogName,
String schemaName,
String tableName,
String columnName)
getColumns operation handler
|
OperationHandle |
HiveSessionImpl.getCrossReference(String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
OperationHandle |
HiveSession.getCrossReference(String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable)
getCrossReference operation handler
|
String |
HiveSessionImplwithUGI.getDelegationToken(HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
HiveSessionImpl.getDelegationToken(HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
HiveSession.getDelegationToken(HiveAuthFactory authFactory,
String owner,
String renewer) |
OperationHandle |
HiveSessionImpl.getFunctions(String catalogName,
String schemaName,
String functionName) |
OperationHandle |
HiveSession.getFunctions(String catalogName,
String schemaName,
String functionName)
getFunctions operation handler
|
GetInfoValue |
HiveSessionImpl.getInfo(GetInfoType getInfoType) |
GetInfoValue |
HiveSession.getInfo(GetInfoType getInfoType)
getInfo operation handler
|
IMetaStoreClient |
HiveSessionImplwithUGI.getMetaStoreClient() |
IMetaStoreClient |
HiveSessionImpl.getMetaStoreClient() |
IMetaStoreClient |
HiveSession.getMetaStoreClient() |
OperationHandle |
HiveSessionImpl.getPrimaryKeys(String catalog,
String schema,
String table) |
OperationHandle |
HiveSession.getPrimaryKeys(String catalog,
String schema,
String table)
getPrimaryKeys operation handler
|
static HiveSession |
HiveSessionProxy.getProxy(HiveSession hiveSession,
org.apache.hadoop.security.UserGroupInformation ugi) |
TableSchema |
HiveSessionImpl.getResultSetMetadata(OperationHandle opHandle) |
TableSchema |
HiveSession.getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
HiveSessionImpl.getSchemas(String catalogName,
String schemaName) |
OperationHandle |
HiveSession.getSchemas(String catalogName,
String schemaName)
getSchemas operation handler
|
HiveSession |
SessionManager.getSession(SessionHandle sessionHandle) |
Hive |
HiveSession.getSessionHive() |
OperationHandle |
HiveSessionImpl.getTables(String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
HiveSession.getTables(String catalogName,
String schemaName,
String tableName,
List<String> tableTypes)
getTables operation handler
|
OperationHandle |
HiveSessionImpl.getTableTypes() |
OperationHandle |
HiveSession.getTableTypes()
getTableTypes operation handler
|
OperationHandle |
HiveSessionImpl.getTypeInfo() |
OperationHandle |
HiveSession.getTypeInfo()
getTypeInfo operation handler
|
void |
HiveSessionImpl.open(Map<String,String> sessionConfMap) |
SessionHandle |
SessionManager.openSession(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> sessionConf) |
SessionHandle |
SessionManager.openSession(TProtocolVersion protocol,
String username,
String password,
String ipAddress,
Map<String,String> sessionConf,
boolean withImpersonation,
String delegationToken)
Opens a new session and creates a session handle.
|
void |
HiveSessionImplwithUGI.renewDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSessionImpl.renewDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSession.renewDelegationToken(HiveAuthFactory authFactory,
String tokenStr) |
void |
HiveSessionHook.run(HiveSessionHookContext sessionHookContext) |
void |
HiveSessionImplwithUGI.setSessionUGI(String owner) |
Constructor and Description |
---|
HiveSessionImplwithUGI(SessionHandle sessionHandle,
TProtocolVersion protocol,
String username,
String password,
HiveConf hiveConf,
String ipAddress,
String delegationToken) |
HiveSessionImplwithUGI(TProtocolVersion protocol,
String username,
String password,
HiveConf hiveConf,
String ipAddress,
String delegationToken) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftCLIServiceClient.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.cancelDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
ThriftCLIServiceClient.cancelOperation(OperationHandle opHandle) |
void |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.cancelOperation(OperationHandle opHandle) |
void |
ThriftCLIServiceClient.checkStatus(TStatus status) |
void |
ThriftCLIServiceClient.closeOperation(OperationHandle opHandle) |
void |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.closeOperation(OperationHandle opHandle) |
void |
ThriftCLIServiceClient.closeSession(SessionHandle sessionHandle) |
void |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.closeSession(SessionHandle sessionHandle) |
protected org.apache.thrift.transport.TTransport |
RetryingThriftCLIServiceClient.connect(HiveConf conf) |
protected org.apache.thrift.transport.TTransport |
RetryingThriftCLIServiceClient.connectWithRetry(int retries) |
OperationHandle |
ThriftCLIServiceClient.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
ThriftCLIServiceClient.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.executeStatement(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
ThriftCLIServiceClient.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay) |
OperationHandle |
ThriftCLIServiceClient.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.executeStatementAsync(SessionHandle sessionHandle,
String statement,
Map<String,String> confOverlay,
long queryTimeout) |
RowSet |
ThriftCLIServiceClient.fetchResults(OperationHandle opHandle) |
RowSet |
ThriftCLIServiceClient.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
RowSet |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows,
FetchType fetchType) |
OperationHandle |
ThriftCLIServiceClient.getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getCatalogs(SessionHandle sessionHandle) |
OperationHandle |
ThriftCLIServiceClient.getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getColumns(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
String columnName) |
OperationHandle |
ThriftCLIServiceClient.getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getCrossReference(SessionHandle sessionHandle,
String primaryCatalog,
String primarySchema,
String primaryTable,
String foreignCatalog,
String foreignSchema,
String foreignTable) |
String |
ThriftCLIServiceClient.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
String |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String owner,
String renewer) |
OperationHandle |
ThriftCLIServiceClient.getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getFunctions(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String functionName) |
GetInfoValue |
ThriftCLIServiceClient.getInfo(SessionHandle sessionHandle,
GetInfoType infoType) |
GetInfoValue |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getInfo(SessionHandle sessionHandle,
GetInfoType getInfoType) |
OperationStatus |
ThriftCLIServiceClient.getOperationStatus(OperationHandle opHandle) |
OperationStatus |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getOperationStatus(OperationHandle opHandle) |
OperationHandle |
ThriftCLIServiceClient.getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getPrimaryKeys(SessionHandle sessionHandle,
String catalog,
String schema,
String table) |
TableSchema |
ThriftCLIServiceClient.getResultSetMetadata(OperationHandle opHandle) |
TableSchema |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
ThriftCLIServiceClient.getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getSchemas(SessionHandle sessionHandle,
String catalogName,
String schemaName) |
OperationHandle |
ThriftCLIServiceClient.getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getTables(SessionHandle sessionHandle,
String catalogName,
String schemaName,
String tableName,
List<String> tableTypes) |
OperationHandle |
ThriftCLIServiceClient.getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getTableTypes(SessionHandle sessionHandle) |
OperationHandle |
ThriftCLIServiceClient.getTypeInfo(SessionHandle sessionHandle) |
OperationHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.getTypeInfo(SessionHandle sessionHandle) |
static RetryingThriftCLIServiceClient.CLIServiceClientWrapper |
RetryingThriftCLIServiceClient.newRetryingCLIServiceClient(HiveConf conf) |
SessionHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.openSession(String username,
String password) |
SessionHandle |
ThriftCLIServiceClient.openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.openSession(String username,
String password,
Map<String,String> configuration) |
SessionHandle |
ThriftCLIServiceClient.openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
SessionHandle |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.openSessionWithImpersonation(String username,
String password,
Map<String,String> configuration,
String delegationToken) |
void |
ThriftCLIServiceClient.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
void |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper.renewDelegationToken(SessionHandle sessionHandle,
HiveAuthFactory authFactory,
String tokenStr) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.