org.apache.hive.service.cli

Class EmbeddedCLIServiceClient

java.lang.Object

org.apache.hive.service.cli.CLIServiceClient

org.apache.hive.service.cli.EmbeddedCLIServiceClient

All Implemented Interfaces:

ICLIService

public class EmbeddedCLIServiceClient
extends CLIServiceClient

EmbeddedCLIServiceClient.

Constructor Summary

Constructors

Constructor and Description
EmbeddedCLIServiceClient(ICLIService cliService)

Method Summary

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)
OperationHandle	executeStatement(SessionHandle sessionHandle, String statement, Map<String,String> confOverlay)
OperationHandle	executeStatementAsync(SessionHandle sessionHandle, String statement, Map<String,String> confOverlay)
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)
String	getDelegationToken(SessionHandle sessionHandle, HiveAuthFactory authFactory, String owner, String renewer)
OperationHandle	getFunctions(SessionHandle sessionHandle, String catalogName, String schemaName, String functionName)
GetInfoValue	getInfo(SessionHandle sessionHandle, GetInfoType getInfoType)
OperationStatus	getOperationStatus(OperationHandle opHandle)
TableSchema	getResultSetMetadata(OperationHandle opHandle)
OperationHandle	getSchemas(SessionHandle sessionHandle, String catalogName, String schemaName)
OperationHandle	getTables(SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, List<String> tableTypes)
OperationHandle	getTableTypes(SessionHandle sessionHandle)
OperationHandle	getTypeInfo(SessionHandle sessionHandle)
SessionHandle	openSession(String username, String password, Map<String,String> configuration)
SessionHandle	openSessionWithImpersonation(String username, String password, Map<String,String> configuration, String delegationToken)
void	renewDelegationToken(SessionHandle sessionHandle, HiveAuthFactory authFactory, String tokenStr)

Methods inherited from class org.apache.hive.service.cli.CLIServiceClient

fetchResults, openSession

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmbeddedCLIServiceClient

public EmbeddedCLIServiceClient(ICLIService cliService)

Method Detail

openSession

public SessionHandle openSession(String username,
                        String password,
                        Map<String,String> configuration)
                          throws HiveSQLException

Throws:

HiveSQLException

openSessionWithImpersonation

public SessionHandle openSessionWithImpersonation(String username,
                                         String password,
                                         Map<String,String> configuration,
                                         String delegationToken)
                                           throws HiveSQLException

Throws:

HiveSQLException

closeSession

public void closeSession(SessionHandle sessionHandle)
                  throws HiveSQLException

Throws:

HiveSQLException

getInfo

public GetInfoValue getInfo(SessionHandle sessionHandle,
                   GetInfoType getInfoType)
                     throws HiveSQLException

Throws:

HiveSQLException

executeStatement

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

Throws:

HiveSQLException

executeStatementAsync

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

Throws:

HiveSQLException

getTypeInfo

public OperationHandle getTypeInfo(SessionHandle sessionHandle)
                            throws HiveSQLException

Throws:

HiveSQLException

getCatalogs

public OperationHandle getCatalogs(SessionHandle sessionHandle)
                            throws HiveSQLException

Throws:

HiveSQLException

getSchemas

public OperationHandle getSchemas(SessionHandle sessionHandle,
                         String catalogName,
                         String schemaName)
                           throws HiveSQLException

Throws:

HiveSQLException

getTables

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

Throws:

HiveSQLException

getTableTypes

public OperationHandle getTableTypes(SessionHandle sessionHandle)
                              throws HiveSQLException

Throws:

HiveSQLException

getColumns

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

Throws:

HiveSQLException

getFunctions

public OperationHandle getFunctions(SessionHandle sessionHandle,
                           String catalogName,
                           String schemaName,
                           String functionName)
                             throws HiveSQLException

Throws:

HiveSQLException

getOperationStatus

public OperationStatus getOperationStatus(OperationHandle opHandle)
                                   throws HiveSQLException

Throws:

HiveSQLException

cancelOperation

public void cancelOperation(OperationHandle opHandle)
                     throws HiveSQLException

Throws:

HiveSQLException

closeOperation

public void closeOperation(OperationHandle opHandle)
                    throws HiveSQLException

Throws:

HiveSQLException

getResultSetMetadata

public TableSchema getResultSetMetadata(OperationHandle opHandle)
                                 throws HiveSQLException

Throws:

HiveSQLException

fetchResults

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

Throws:

HiveSQLException

getDelegationToken

public String getDelegationToken(SessionHandle sessionHandle,
                        HiveAuthFactory authFactory,
                        String owner,
                        String renewer)
                          throws HiveSQLException

Specified by:

getDelegationToken in interface ICLIService

Specified by:

getDelegationToken in class CLIServiceClient

Throws:

HiveSQLException

cancelDelegationToken

public void cancelDelegationToken(SessionHandle sessionHandle,
                         HiveAuthFactory authFactory,
                         String tokenStr)
                           throws HiveSQLException

Specified by:

cancelDelegationToken in interface ICLIService

Specified by:

cancelDelegationToken in class CLIServiceClient

Throws:

HiveSQLException

renewDelegationToken

public void renewDelegationToken(SessionHandle sessionHandle,
                        HiveAuthFactory authFactory,
                        String tokenStr)
                          throws HiveSQLException

Specified by:

renewDelegationToken in interface ICLIService

Specified by:

renewDelegationToken in class CLIServiceClient

Throws:

HiveSQLException