@InterfaceAudience.Public
public interface RpcRetryingCaller<T>
Modifier and Type | Method and Description |
---|---|
T |
callWithoutRetries(RetryingCallable<T> callable,
int callTimeout)
Call the server once only.
|
T |
callWithRetries(RetryingCallable<T> callable,
int callTimeout)
Retries if invocation fails.
|
void |
cancel() |
void cancel()
T callWithRetries(RetryingCallable<T> callable, int callTimeout) throws IOException, RuntimeException
callTimeout
- Timeout for this callcallable
- The RetryingCallable
to run.IOException
- if a remote or network exception occursRuntimeException
- other unspecified errorT callWithoutRetries(RetryingCallable<T> callable, int callTimeout) throws IOException, RuntimeException
RetryingCallable
has a strange shape so we can do retries. Use this invocation if you
want to do a single call only (A call to RetryingCallable.call(int)
will not likely
succeed).IOException
- if a remote or network exception occursRuntimeException
- other unspecified errorCopyright © 2007–2019 Cloudera. All rights reserved.