org.apache.lens.driver.hive

Class EmbeddedThriftConnection.EmbeddedThriftCLIServiceClient

java.lang.Object

org.apache.hive.service.cli.CLIServiceClient

org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

org.apache.lens.driver.hive.EmbeddedThriftConnection.EmbeddedThriftCLIServiceClient

All Implemented Interfaces:

org.apache.hive.service.cli.ICLIService

Enclosing class:

EmbeddedThriftConnection

public static class EmbeddedThriftConnection.EmbeddedThriftCLIServiceClient
extends org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Constructor Summary

Constructors

Constructor and Description
EmbeddedThriftCLIServiceClient(org.apache.hive.service.rpc.thrift.TCLIService.Iface cliService)

Method Summary

Modifier and Type	Method and Description
void	cancelDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle, org.apache.hive.service.auth.HiveAuthFactory authFactory, String tokenStr)
void	cancelOperation(org.apache.hive.service.cli.OperationHandle opHandle)
void	closeOperation(org.apache.hive.service.cli.OperationHandle opHandle)
void	closeSession(org.apache.hive.service.cli.SessionHandle sessionHandle)
org.apache.hive.service.cli.OperationHandle	executeStatement(org.apache.hive.service.cli.SessionHandle sessionHandle, String statement, Map<String,String> confOverlay)
org.apache.hive.service.cli.OperationHandle	executeStatementAsync(org.apache.hive.service.cli.SessionHandle sessionHandle, String statement, Map<String,String> confOverlay)
org.apache.hive.service.cli.RowSet	fetchResults(org.apache.hive.service.cli.OperationHandle opHandle)
org.apache.hive.service.cli.RowSet	fetchResults(org.apache.hive.service.cli.OperationHandle opHandle, org.apache.hive.service.cli.FetchOrientation orientation, long maxRows, org.apache.hive.service.cli.FetchType fetchType)
org.apache.hive.service.cli.OperationHandle	getCatalogs(org.apache.hive.service.cli.SessionHandle sessionHandle)
org.apache.hive.service.cli.OperationHandle	getColumns(org.apache.hive.service.cli.SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, String columnName)
String	getDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle, org.apache.hive.service.auth.HiveAuthFactory authFactory, String owner, String renewer)
org.apache.hive.service.cli.OperationHandle	getFunctions(org.apache.hive.service.cli.SessionHandle sessionHandle, String catalogName, String schemaName, String functionName)
org.apache.hive.service.cli.GetInfoValue	getInfo(org.apache.hive.service.cli.SessionHandle sessionHandle, org.apache.hive.service.cli.GetInfoType infoType)
org.apache.hive.service.cli.TableSchema	getResultSetMetadata(org.apache.hive.service.cli.OperationHandle opHandle)
org.apache.hive.service.cli.OperationHandle	getSchemas(org.apache.hive.service.cli.SessionHandle sessionHandle, String catalogName, String schemaName)
org.apache.hive.service.cli.OperationHandle	getTables(org.apache.hive.service.cli.SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, List<String> tableTypes)
org.apache.hive.service.cli.OperationHandle	getTableTypes(org.apache.hive.service.cli.SessionHandle sessionHandle)
org.apache.hive.service.cli.OperationHandle	getTypeInfo(org.apache.hive.service.cli.SessionHandle sessionHandle)
org.apache.hive.service.cli.SessionHandle	openSession(String username, String password)
org.apache.hive.service.cli.SessionHandle	openSession(String username, String password, Map<String,String> configuration)
org.apache.hive.service.cli.SessionHandle	openSessionWithImpersonation(String username, String password, Map<String,String> configuration, String delegationToken)
void	renewDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle, org.apache.hive.service.auth.HiveAuthFactory authFactory, String tokenStr)

Methods inherited from class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

checkStatus, executeStatement, executeStatementAsync, getCrossReference, getOperationStatus, getPrimaryKeys

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedThriftCLIServiceClient

public EmbeddedThriftCLIServiceClient(org.apache.hive.service.rpc.thrift.TCLIService.Iface cliService)

Method Detail

openSession

public org.apache.hive.service.cli.SessionHandle openSession(String username,
                                                             String password,
                                                             Map<String,String> configuration)
                                                      throws org.apache.hive.service.cli.HiveSQLException

Specified by:

openSession in interface org.apache.hive.service.cli.ICLIService

Overrides:

openSession in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

openSessionWithImpersonation

public org.apache.hive.service.cli.SessionHandle openSessionWithImpersonation(String username,
                                                                              String password,
                                                                              Map<String,String> configuration,
                                                                              String delegationToken)
                                                                       throws org.apache.hive.service.cli.HiveSQLException

Specified by:

openSessionWithImpersonation in interface org.apache.hive.service.cli.ICLIService

Overrides:

openSessionWithImpersonation in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

closeSession

public void closeSession(org.apache.hive.service.cli.SessionHandle sessionHandle)
                  throws org.apache.hive.service.cli.HiveSQLException

Specified by:

closeSession in interface org.apache.hive.service.cli.ICLIService

Overrides:

closeSession in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getInfo

public org.apache.hive.service.cli.GetInfoValue getInfo(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                        org.apache.hive.service.cli.GetInfoType infoType)
                                                 throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getInfo in interface org.apache.hive.service.cli.ICLIService

Overrides:

getInfo in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

executeStatement

public org.apache.hive.service.cli.OperationHandle executeStatement(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                                    String statement,
                                                                    Map<String,String> confOverlay)
                                                             throws org.apache.hive.service.cli.HiveSQLException

Specified by:

executeStatement in interface org.apache.hive.service.cli.ICLIService

Overrides:

executeStatement in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

executeStatementAsync

public org.apache.hive.service.cli.OperationHandle executeStatementAsync(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                                         String statement,
                                                                         Map<String,String> confOverlay)
                                                                  throws org.apache.hive.service.cli.HiveSQLException

Specified by:

executeStatementAsync in interface org.apache.hive.service.cli.ICLIService

Overrides:

executeStatementAsync in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getTypeInfo

public org.apache.hive.service.cli.OperationHandle getTypeInfo(org.apache.hive.service.cli.SessionHandle sessionHandle)
                                                        throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getTypeInfo in interface org.apache.hive.service.cli.ICLIService

Overrides:

getTypeInfo in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getCatalogs

public org.apache.hive.service.cli.OperationHandle getCatalogs(org.apache.hive.service.cli.SessionHandle sessionHandle)
                                                        throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getCatalogs in interface org.apache.hive.service.cli.ICLIService

Overrides:

getCatalogs in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getSchemas

public org.apache.hive.service.cli.OperationHandle getSchemas(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                              String catalogName,
                                                              String schemaName)
                                                       throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getSchemas in interface org.apache.hive.service.cli.ICLIService

Overrides:

getSchemas in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getTables

public org.apache.hive.service.cli.OperationHandle getTables(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                             String catalogName,
                                                             String schemaName,
                                                             String tableName,
                                                             List<String> tableTypes)
                                                      throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getTables in interface org.apache.hive.service.cli.ICLIService

Overrides:

getTables in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getTableTypes

public org.apache.hive.service.cli.OperationHandle getTableTypes(org.apache.hive.service.cli.SessionHandle sessionHandle)
                                                          throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getTableTypes in interface org.apache.hive.service.cli.ICLIService

Overrides:

getTableTypes in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getColumns

public org.apache.hive.service.cli.OperationHandle getColumns(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                              String catalogName,
                                                              String schemaName,
                                                              String tableName,
                                                              String columnName)
                                                       throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getColumns in interface org.apache.hive.service.cli.ICLIService

Overrides:

getColumns in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getFunctions

public org.apache.hive.service.cli.OperationHandle getFunctions(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                                                String catalogName,
                                                                String schemaName,
                                                                String functionName)
                                                         throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getFunctions in interface org.apache.hive.service.cli.ICLIService

Overrides:

getFunctions in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

cancelOperation

public void cancelOperation(org.apache.hive.service.cli.OperationHandle opHandle)
                     throws org.apache.hive.service.cli.HiveSQLException

Specified by:

cancelOperation in interface org.apache.hive.service.cli.ICLIService

Overrides:

cancelOperation in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

closeOperation

public void closeOperation(org.apache.hive.service.cli.OperationHandle opHandle)
                    throws org.apache.hive.service.cli.HiveSQLException

Specified by:

closeOperation in interface org.apache.hive.service.cli.ICLIService

Overrides:

closeOperation in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getResultSetMetadata

public org.apache.hive.service.cli.TableSchema getResultSetMetadata(org.apache.hive.service.cli.OperationHandle opHandle)
                                                             throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getResultSetMetadata in interface org.apache.hive.service.cli.ICLIService

Overrides:

getResultSetMetadata in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

fetchResults

public org.apache.hive.service.cli.RowSet fetchResults(org.apache.hive.service.cli.OperationHandle opHandle)
                                                throws org.apache.hive.service.cli.HiveSQLException

Specified by:

fetchResults in interface org.apache.hive.service.cli.ICLIService

Overrides:

fetchResults in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

fetchResults

public org.apache.hive.service.cli.RowSet fetchResults(org.apache.hive.service.cli.OperationHandle opHandle,
                                                       org.apache.hive.service.cli.FetchOrientation orientation,
                                                       long maxRows,
                                                       org.apache.hive.service.cli.FetchType fetchType)
                                                throws org.apache.hive.service.cli.HiveSQLException

Specified by:

fetchResults in interface org.apache.hive.service.cli.ICLIService

Overrides:

fetchResults in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

getDelegationToken

public String getDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                 org.apache.hive.service.auth.HiveAuthFactory authFactory,
                                 String owner,
                                 String renewer)
                          throws org.apache.hive.service.cli.HiveSQLException

Specified by:

getDelegationToken in interface org.apache.hive.service.cli.ICLIService

Overrides:

getDelegationToken in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

cancelDelegationToken

public void cancelDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                  org.apache.hive.service.auth.HiveAuthFactory authFactory,
                                  String tokenStr)
                           throws org.apache.hive.service.cli.HiveSQLException

Specified by:

cancelDelegationToken in interface org.apache.hive.service.cli.ICLIService

Overrides:

cancelDelegationToken in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

renewDelegationToken

public void renewDelegationToken(org.apache.hive.service.cli.SessionHandle sessionHandle,
                                 org.apache.hive.service.auth.HiveAuthFactory authFactory,
                                 String tokenStr)
                          throws org.apache.hive.service.cli.HiveSQLException

Specified by:

renewDelegationToken in interface org.apache.hive.service.cli.ICLIService

Overrides:

renewDelegationToken in class org.apache.hive.service.cli.thrift.ThriftCLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException

openSession

public org.apache.hive.service.cli.SessionHandle openSession(String username,
                                                             String password)
                                                      throws org.apache.hive.service.cli.HiveSQLException

Overrides:

openSession in class org.apache.hive.service.cli.CLIServiceClient

Throws:

org.apache.hive.service.cli.HiveSQLException