org.apache.hive.service.cli.thrift

Class ThriftCLIService

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.cli.thrift.ThriftCLIService

All Implemented Interfaces:

Runnable, org.apache.hive.service.rpc.thrift.TCLIService.Iface, Service

Direct Known Subclasses:

ThriftBinaryCLIService, ThriftHttpCLIService

public abstract class ThriftCLIService
extends AbstractService
implements org.apache.hive.service.rpc.thrift.TCLIService.Iface, Runnable

ThriftCLIService.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hive.service.Service

Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
protected CLIService	cliService
protected ThreadLocal<org.apache.thrift.server.ServerContext>	currentServerContext
protected static HiveAuthFactory	hiveAuthFactory
protected HiveConf	hiveConf
protected String	hiveHost
protected boolean	isEmbedded
static org.slf4j.Logger	LOG
protected int	maxWorkerThreads
protected int	minWorkerThreads
protected int	portNum
protected InetAddress	serverIPAddress
protected long	workerKeepAliveTime

Constructor Summary

Constructors

Constructor and Description
ThriftCLIService(CLIService service, String serviceName)

Method Summary

Modifier and Type	Method and Description
org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp	CancelDelegationToken(org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq req)
org.apache.hive.service.rpc.thrift.TCancelOperationResp	CancelOperation(org.apache.hive.service.rpc.thrift.TCancelOperationReq req)
org.apache.hive.service.rpc.thrift.TCloseOperationResp	CloseOperation(org.apache.hive.service.rpc.thrift.TCloseOperationReq req)
org.apache.hive.service.rpc.thrift.TCloseSessionResp	CloseSession(org.apache.hive.service.rpc.thrift.TCloseSessionReq req)
org.apache.hive.service.rpc.thrift.TExecuteStatementResp	ExecuteStatement(org.apache.hive.service.rpc.thrift.TExecuteStatementReq req)
org.apache.hive.service.rpc.thrift.TFetchResultsResp	FetchResults(org.apache.hive.service.rpc.thrift.TFetchResultsReq req)
org.apache.hive.service.rpc.thrift.TGetCatalogsResp	GetCatalogs(org.apache.hive.service.rpc.thrift.TGetCatalogsReq req)
org.apache.hive.service.rpc.thrift.TGetColumnsResp	GetColumns(org.apache.hive.service.rpc.thrift.TGetColumnsReq req)
org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp	GetCrossReference(org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq req)
org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp	GetDelegationToken(org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq req)
org.apache.hive.service.rpc.thrift.TGetFunctionsResp	GetFunctions(org.apache.hive.service.rpc.thrift.TGetFunctionsReq req)
org.apache.hive.service.rpc.thrift.TGetInfoResp	GetInfo(org.apache.hive.service.rpc.thrift.TGetInfoReq req)
org.apache.hive.service.rpc.thrift.TGetOperationStatusResp	GetOperationStatus(org.apache.hive.service.rpc.thrift.TGetOperationStatusReq req)
int	getPortNumber()
org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp	GetPrimaryKeys(org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq req)
org.apache.hive.service.rpc.thrift.TGetQueryIdResp	GetQueryId(org.apache.hive.service.rpc.thrift.TGetQueryIdReq req)
org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp	GetResultSetMetadata(org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq req)
org.apache.hive.service.rpc.thrift.TGetSchemasResp	GetSchemas(org.apache.hive.service.rpc.thrift.TGetSchemasReq req)
InetAddress	getServerIPAddress()
org.apache.hive.service.rpc.thrift.TGetTablesResp	GetTables(org.apache.hive.service.rpc.thrift.TGetTablesReq req)
org.apache.hive.service.rpc.thrift.TGetTableTypesResp	GetTableTypes(org.apache.hive.service.rpc.thrift.TGetTableTypesReq req)
org.apache.hive.service.rpc.thrift.TGetTypeInfoResp	GetTypeInfo(org.apache.hive.service.rpc.thrift.TGetTypeInfoReq req)
void	init(HiveConf hiveConf) Initialize the service.
protected abstract void	initServer()
org.apache.hive.service.rpc.thrift.TOpenSessionResp	OpenSession(org.apache.hive.service.rpc.thrift.TOpenSessionReq req)
org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp	RenewDelegationToken(org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq req)
abstract void	run()
org.apache.hive.service.rpc.thrift.TSetClientInfoResp	SetClientInfo(org.apache.hive.service.rpc.thrift.TSetClientInfoReq req)
void	start() Start the service.
void	stop() Stop the service.
protected abstract void	stopServer()

Methods inherited from class org.apache.hive.service.AbstractService

getHiveConf, getName, getServiceState, getStartTime, register, setHiveConf, unregister

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

cliService

protected CLIService cliService

hiveAuthFactory

protected static HiveAuthFactory hiveAuthFactory

portNum

protected int portNum

serverIPAddress

protected InetAddress serverIPAddress

hiveHost

protected String hiveHost

isEmbedded

protected boolean isEmbedded

hiveConf

protected HiveConf hiveConf

minWorkerThreads

protected int minWorkerThreads

maxWorkerThreads

protected int maxWorkerThreads

workerKeepAliveTime

protected long workerKeepAliveTime

currentServerContext

protected ThreadLocal<org.apache.thrift.server.ServerContext> currentServerContext

Constructor Detail

ThriftCLIService

public ThriftCLIService(CLIService service,
                        String serviceName)

Method Detail

init

public void init(HiveConf hiveConf)

Description copied from class: AbstractService

Initialize the service. The transition must be from Service.STATE.NOTINITED to Service.STATE.INITED unless the operation failed and an exception was raised.

Specified by:

init in interface Service

Overrides:

init in class AbstractService

initServer

protected abstract void initServer()

start

public void start()

Description copied from class: AbstractService

Start the service. The transition should be from Service.STATE.INITED to Service.STATE.STARTED unless the operation failed and an exception was raised.

Specified by:

start in interface Service

Overrides:

start in class AbstractService

stopServer

protected abstract void stopServer()

stop

public void stop()

Description copied from class: AbstractService

Stop the service. This operation must be designed to complete regardless of the initial state of the service, including the state of all its internal fields.

Specified by:

stop in interface Service

Overrides:

stop in class AbstractService

getPortNumber

public int getPortNumber()

getServerIPAddress

public InetAddress getServerIPAddress()

GetDelegationToken

public org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp GetDelegationToken(org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq req)
                                                                              throws org.apache.thrift.TException

Specified by:

GetDelegationToken in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

CancelDelegationToken

public org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp CancelDelegationToken(org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq req)
                                                                                    throws org.apache.thrift.TException

Specified by:

CancelDelegationToken in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

RenewDelegationToken

public org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp RenewDelegationToken(org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq req)
                                                                                  throws org.apache.thrift.TException

Specified by:

RenewDelegationToken in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

OpenSession

public org.apache.hive.service.rpc.thrift.TOpenSessionResp OpenSession(org.apache.hive.service.rpc.thrift.TOpenSessionReq req)
                                                                throws org.apache.thrift.TException

Specified by:

OpenSession in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

SetClientInfo

public org.apache.hive.service.rpc.thrift.TSetClientInfoResp SetClientInfo(org.apache.hive.service.rpc.thrift.TSetClientInfoReq req)
                                                                    throws org.apache.thrift.TException

Specified by:

SetClientInfo in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

CloseSession

public org.apache.hive.service.rpc.thrift.TCloseSessionResp CloseSession(org.apache.hive.service.rpc.thrift.TCloseSessionReq req)
                                                                  throws org.apache.thrift.TException

Specified by:

CloseSession in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetInfo

public org.apache.hive.service.rpc.thrift.TGetInfoResp GetInfo(org.apache.hive.service.rpc.thrift.TGetInfoReq req)
                                                        throws org.apache.thrift.TException

Specified by:

GetInfo in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

ExecuteStatement

public org.apache.hive.service.rpc.thrift.TExecuteStatementResp ExecuteStatement(org.apache.hive.service.rpc.thrift.TExecuteStatementReq req)
                                                                          throws org.apache.thrift.TException

Specified by:

ExecuteStatement in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTypeInfo

public org.apache.hive.service.rpc.thrift.TGetTypeInfoResp GetTypeInfo(org.apache.hive.service.rpc.thrift.TGetTypeInfoReq req)
                                                                throws org.apache.thrift.TException

Specified by:

GetTypeInfo in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetCatalogs

public org.apache.hive.service.rpc.thrift.TGetCatalogsResp GetCatalogs(org.apache.hive.service.rpc.thrift.TGetCatalogsReq req)
                                                                throws org.apache.thrift.TException

Specified by:

GetCatalogs in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetSchemas

public org.apache.hive.service.rpc.thrift.TGetSchemasResp GetSchemas(org.apache.hive.service.rpc.thrift.TGetSchemasReq req)
                                                              throws org.apache.thrift.TException

Specified by:

GetSchemas in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTables

public org.apache.hive.service.rpc.thrift.TGetTablesResp GetTables(org.apache.hive.service.rpc.thrift.TGetTablesReq req)
                                                            throws org.apache.thrift.TException

Specified by:

GetTables in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTableTypes

public org.apache.hive.service.rpc.thrift.TGetTableTypesResp GetTableTypes(org.apache.hive.service.rpc.thrift.TGetTableTypesReq req)
                                                                    throws org.apache.thrift.TException

Specified by:

GetTableTypes in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetColumns

public org.apache.hive.service.rpc.thrift.TGetColumnsResp GetColumns(org.apache.hive.service.rpc.thrift.TGetColumnsReq req)
                                                              throws org.apache.thrift.TException

Specified by:

GetColumns in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetFunctions

public org.apache.hive.service.rpc.thrift.TGetFunctionsResp GetFunctions(org.apache.hive.service.rpc.thrift.TGetFunctionsReq req)
                                                                  throws org.apache.thrift.TException

Specified by:

GetFunctions in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetOperationStatus

public org.apache.hive.service.rpc.thrift.TGetOperationStatusResp GetOperationStatus(org.apache.hive.service.rpc.thrift.TGetOperationStatusReq req)
                                                                              throws org.apache.thrift.TException

Specified by:

GetOperationStatus in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

CancelOperation

public org.apache.hive.service.rpc.thrift.TCancelOperationResp CancelOperation(org.apache.hive.service.rpc.thrift.TCancelOperationReq req)
                                                                        throws org.apache.thrift.TException

Specified by:

CancelOperation in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

CloseOperation

public org.apache.hive.service.rpc.thrift.TCloseOperationResp CloseOperation(org.apache.hive.service.rpc.thrift.TCloseOperationReq req)
                                                                      throws org.apache.thrift.TException

Specified by:

CloseOperation in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetResultSetMetadata

public org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp GetResultSetMetadata(org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq req)
                                                                                  throws org.apache.thrift.TException

Specified by:

GetResultSetMetadata in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

FetchResults

public org.apache.hive.service.rpc.thrift.TFetchResultsResp FetchResults(org.apache.hive.service.rpc.thrift.TFetchResultsReq req)
                                                                  throws org.apache.thrift.TException

Specified by:

FetchResults in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetPrimaryKeys

public org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp GetPrimaryKeys(org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq req)
                                                                      throws org.apache.thrift.TException

Specified by:

GetPrimaryKeys in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetCrossReference

public org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp GetCrossReference(org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq req)
                                                                            throws org.apache.thrift.TException

Specified by:

GetCrossReference in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

GetQueryId

public org.apache.hive.service.rpc.thrift.TGetQueryIdResp GetQueryId(org.apache.hive.service.rpc.thrift.TGetQueryIdReq req)
                                                              throws org.apache.thrift.TException

Specified by:

GetQueryId in interface org.apache.hive.service.rpc.thrift.TCLIService.Iface

Throws:

org.apache.thrift.TException

run

public abstract void run()

Specified by:

run in interface Runnable