public class RetryingThriftCLIServiceClient extends Object implements InvocationHandler
Modifier and Type | Class and Description |
---|---|
static class |
RetryingThriftCLIServiceClient.CLIServiceClientWrapper |
protected class |
RetryingThriftCLIServiceClient.InvocationResult |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Modifier | Constructor and Description |
---|---|
protected |
RetryingThriftCLIServiceClient(HiveConf conf) |
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) |
protected RetryingThriftCLIServiceClient(HiveConf conf)
public static RetryingThriftCLIServiceClient.CLIServiceClientWrapper newRetryingCLIServiceClient(HiveConf conf) throws HiveSQLException
HiveSQLException
protected org.apache.thrift.transport.TTransport connectWithRetry(int retries) throws HiveSQLException
HiveSQLException
protected org.apache.thrift.transport.TTransport connect(HiveConf conf) throws HiveSQLException, org.apache.thrift.transport.TTransportException
HiveSQLException
org.apache.thrift.transport.TTransportException
protected RetryingThriftCLIServiceClient.InvocationResult invokeInternal(Method method, Object[] args) throws Throwable
Throwable
public Object invoke(Object o, Method method, Object[] args) throws Throwable
invoke
in interface InvocationHandler
Throwable
public int getRetryLimit()
public int getRetryDelaySeconds()
Copyright © 2021 The Apache Software Foundation. All rights reserved.