org.apache.hive.service.cli.thrift

Class RetryingThriftCLIServiceClient

java.lang.Object

org.apache.hive.service.cli.thrift.RetryingThriftCLIServiceClient

All Implemented Interfaces:

InvocationHandler

public class RetryingThriftCLIServiceClient
extends Object
implements InvocationHandler

RetryingThriftCLIServiceClient. Creates a proxy for a CLIServiceClient implementation and retries calls to it on failure.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetryingThriftCLIServiceClient.CLIServiceClientWrapper
protected class	RetryingThriftCLIServiceClient.InvocationResult

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RetryingThriftCLIServiceClient(HiveConf conf)

Method Summary

Modifier and Type	Method and Description
protected org.apache.thrift.transport.TTransport	connect(HiveConf conf)
protected org.apache.thrift.transport.TTransport	connectWithRetry(int retries)
int	getRetryDelaySeconds()
int	getRetryLimit()
Object	invoke(Object o, Method method, Object[] args)
protected RetryingThriftCLIServiceClient.InvocationResult	invokeInternal(Method method, Object[] args)
static RetryingThriftCLIServiceClient.CLIServiceClientWrapper	newRetryingCLIServiceClient(HiveConf conf)

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

Constructor Detail

RetryingThriftCLIServiceClient

protected RetryingThriftCLIServiceClient(HiveConf conf)

Method Detail

newRetryingCLIServiceClient

public static RetryingThriftCLIServiceClient.CLIServiceClientWrapper newRetryingCLIServiceClient(HiveConf conf)
                                                                                          throws HiveSQLException

Throws:

HiveSQLException

connectWithRetry

protected org.apache.thrift.transport.TTransport connectWithRetry(int retries)
                                                           throws HiveSQLException

Throws:

HiveSQLException

connect

protected org.apache.thrift.transport.TTransport connect(HiveConf conf)
                                                  throws HiveSQLException,
                                                         org.apache.thrift.transport.TTransportException

Throws:

HiveSQLException

org.apache.thrift.transport.TTransportException

invokeInternal

protected RetryingThriftCLIServiceClient.InvocationResult invokeInternal(Method method,
                                                                         Object[] args)
                                                                  throws Throwable

Throws:

Throwable

invoke

public Object invoke(Object o,
                     Method method,
                     Object[] args)
              throws Throwable

Specified by:

invoke in interface InvocationHandler

Throws:

Throwable

getRetryLimit

public int getRetryLimit()

getRetryDelaySeconds

public int getRetryDelaySeconds()