| Package | Description |
|---|---|
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
FastFailInterceptorContext |
(package private) class |
NoOpRetryingInterceptorContext |
| Modifier and Type | Field and Description |
|---|---|
private RetryingCallerInterceptorContext |
RpcRetryingCaller.context |
private static RetryingCallerInterceptorContext |
NoOpRetryableCallerInterceptor.NO_OP_CONTEXT |
| Modifier and Type | Method and Description |
|---|---|
RetryingCallerInterceptorContext |
PreemptiveFastFailInterceptor.createEmptyContext() |
RetryingCallerInterceptorContext |
NoOpRetryableCallerInterceptor.createEmptyContext() |
abstract RetryingCallerInterceptorContext |
RetryingCallerInterceptor.createEmptyContext()
This returns the context object for the current call.
|
RetryingCallerInterceptorContext |
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable) |
abstract RetryingCallerInterceptorContext |
RetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable)
This prepares the context object by populating it with information specific
to the implementation of the
RetryingCallerInterceptor along with
which this will be used. |
RetryingCallerInterceptorContext |
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable,
int tries) |
abstract RetryingCallerInterceptorContext |
RetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable,
int tries)
Telescopic extension that takes which of the many retries we are currently
in.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PreemptiveFastFailInterceptor.handleFailure(RetryingCallerInterceptorContext context,
Throwable t) |
void |
NoOpRetryableCallerInterceptor.handleFailure(RetryingCallerInterceptorContext context,
Throwable t) |
abstract void |
RetryingCallerInterceptor.handleFailure(RetryingCallerInterceptorContext context,
Throwable t)
Call this function in case we caught a failure during retries.
|
void |
PreemptiveFastFailInterceptor.intercept(RetryingCallerInterceptorContext context) |
void |
NoOpRetryableCallerInterceptor.intercept(RetryingCallerInterceptorContext abstractRetryingCallerInterceptorContext) |
abstract void |
RetryingCallerInterceptor.intercept(RetryingCallerInterceptorContext abstractRetryingCallerInterceptorContext)
Call this function alongside the actual call done on the callable.
|
void |
PreemptiveFastFailInterceptor.updateFailureInfo(RetryingCallerInterceptorContext context) |
void |
NoOpRetryableCallerInterceptor.updateFailureInfo(RetryingCallerInterceptorContext context) |
abstract void |
RetryingCallerInterceptor.updateFailureInfo(RetryingCallerInterceptorContext context)
Call this function to update at the end of the retry.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.