| Package | Description |
|---|---|
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| org.apache.hadoop.hbase.regionserver.wal | |
| org.apache.hadoop.hbase.replication.regionserver |
| Modifier and Type | Class and Description |
|---|---|
class |
DelegatingRetryingCallable<T,D extends RetryingCallable<T>>
Helper callable for internal use when you just want to override a single method of a
RetryingCallable. |
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
ClientSmallReversedScanner.SmallReversedScannerCallable
A reversed ScannerCallable which supports backward small scanning.
|
(package private) static class |
ClientSmallScanner.SmallScannerCallable |
class |
DelegatingRetryingCallable<T,D extends RetryingCallable<T>>
Helper callable for internal use when you just want to override a single method of a
RetryingCallable. |
class |
FlushRegionCallable
A Callable for flushRegion() RPC.
|
(package private) class |
MasterCallable<V>
A RetryingCallable for master operations.
|
(package private) class |
MultiServerCallable<R>
Callable that handles the
multi method call going against a single
regionserver; i.e. |
class |
RegionAdminServiceCallable<T>
Similar to
RegionServerCallable but for the AdminService interface. |
class |
RegionServerCallable<T>
Implementations call a RegionServer and implement
call(int). |
class |
ReversedScannerCallable
A reversed ScannerCallable which supports backward scanning.
|
(package private) class |
RpcRetryingCallerWithReadReplicas.ReplicaRegionServerCallable
A RegionServerCallable that takes into account the replicas, i.e.
|
class |
ScannerCallable
Scanner operations such as create, next, etc.
|
(package private) class |
ScannerCallableWithReplicas
This class has the logic for handling scanners for regions with and without replicas.
|
(package private) class |
ScannerCallableWithReplicas.RetryingRPC |
| Modifier and Type | Field and Description |
|---|---|
protected D |
DelegatingRetryingCallable.delegate |
private RetryingCallable<T> |
ResultBoundedCompletionService.QueueingFuture.future |
| Modifier and Type | Method and Description |
|---|---|
T |
StatsTrackingRpcRetryingCaller.callWithoutRetries(RetryingCallable<T> callable,
int callTimeout) |
T |
RpcRetryingCaller.callWithoutRetries(RetryingCallable<T> callable,
int callTimeout)
Call the server once only.
|
T |
StatsTrackingRpcRetryingCaller.callWithRetries(RetryingCallable<T> callable,
int callTimeout) |
T |
RpcRetryingCaller.callWithRetries(RetryingCallable<T> callable,
int callTimeout)
Retries if invocation fails.
|
RetryingCallerInterceptorContext |
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable) |
FastFailInterceptorContext |
FastFailInterceptorContext.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) |
FastFailInterceptorContext |
FastFailInterceptorContext.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.
|
void |
ResultBoundedCompletionService.submit(RetryingCallable<V> task,
int callTimeout,
int id) |
private T |
StatsTrackingRpcRetryingCaller.updateStatsAndUnwrap(T result,
RetryingCallable<T> callable) |
| Constructor and Description |
|---|
ResultBoundedCompletionService.QueueingFuture(RetryingCallable<T> future,
int callTimeout) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
WALEditsReplaySink.ReplayServerCallable<R>
Callable that handles the
replay method call going against a single regionserver |
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable
Calls replay on the passed edits for the given set of entries belonging to the region.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) RetryingCallable<V> |
RegionReplicaReplicationEndpoint.RetryingRpcCallable.callable |
| Constructor and Description |
|---|
RegionReplicaReplicationEndpoint.RetryingRpcCallable(RpcRetryingCallerFactory factory,
RetryingCallable<V> callable,
int timeout) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.