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, TCLIService.Iface, Service

Direct Known Subclasses:

ThriftBinaryCLIService, ThriftHttpCLIService

public abstract class ThriftCLIService
extends AbstractService
implements 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 org.eclipse.jetty.server.Server	httpServer
protected boolean	isEmbedded
static org.apache.commons.logging.Log	LOG
protected int	maxWorkerThreads
protected int	minWorkerThreads
protected int	portNum
protected org.apache.thrift.server.TServer	server
protected org.apache.thrift.server.TServerEventHandler	serverEventHandler
protected InetAddress	serverIPAddress
protected long	workerKeepAliveTime

Constructor Summary

Constructors

Constructor and Description
ThriftCLIService(CLIService service, String serviceName)

Method Summary

Methods

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

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

getHiveConf, getName, getServiceState, getStartTime, register, 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.apache.commons.logging.Log LOG

cliService

protected CLIService cliService

hiveAuthFactory

protected static HiveAuthFactory hiveAuthFactory

portNum

protected int portNum

serverIPAddress

protected InetAddress serverIPAddress

hiveHost

protected String hiveHost

server

protected org.apache.thrift.server.TServer server

httpServer

protected org.eclipse.jetty.server.Server httpServer

isEmbedded

protected boolean isEmbedded

hiveConf

protected HiveConf hiveConf

minWorkerThreads

protected int minWorkerThreads

maxWorkerThreads

protected int maxWorkerThreads

workerKeepAliveTime

protected long workerKeepAliveTime

serverEventHandler

protected org.apache.thrift.server.TServerEventHandler serverEventHandler

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

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

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 TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req)
                                           throws org.apache.thrift.TException

Specified by:

GetDelegationToken in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

CancelDelegationToken

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

Specified by:

CancelDelegationToken in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

RenewDelegationToken

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

Specified by:

RenewDelegationToken in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

OpenSession

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

Specified by:

OpenSession in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

CloseSession

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

Specified by:

CloseSession in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetInfo

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

Specified by:

GetInfo in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

ExecuteStatement

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

Specified by:

ExecuteStatement in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTypeInfo

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

Specified by:

GetTypeInfo in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetCatalogs

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

Specified by:

GetCatalogs in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetSchemas

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

Specified by:

GetSchemas in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTables

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

Specified by:

GetTables in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetTableTypes

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

Specified by:

GetTableTypes in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetColumns

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

Specified by:

GetColumns in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetFunctions

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

Specified by:

GetFunctions in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetOperationStatus

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

Specified by:

GetOperationStatus in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

CancelOperation

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

Specified by:

CancelOperation in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

CloseOperation

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

Specified by:

CloseOperation in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

GetResultSetMetadata

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

Specified by:

GetResultSetMetadata in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

FetchResults

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

Specified by:

FetchResults in interface TCLIService.Iface

Throws:

org.apache.thrift.TException

run

public abstract void run()

Specified by:

run in interface Runnable