Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Class and Description |
---|---|
(package private) class |
CancellableRegionServerCallable<T>
This class is used to unify HTable calls with AsyncProcess Framework.
|
class |
ClientServiceCallable<T>
A RegionServerCallable set to use the Client protocol.
|
class |
FlushRegionCallable
A Callable for flushRegion() RPC.
|
(package private) class |
MasterCallable<V>
A RetryingCallable for Master RPC operations.
|
(package private) class |
MultiServerCallable
Callable that handles the
multi method call going against a single regionserver;
i.e. |
class |
NoncedRegionServerCallable<T>
Implementations make an rpc call against a RegionService via a protobuf Service.
|
class |
RegionAdminServiceCallable<T>
Similar to RegionServerCallable but for the AdminService interface.
|
class |
RegionServerCallable<T,S>
Implementations make a RPC call against a RegionService via a protobuf Service.
|
class |
ReversedScannerCallable
A reversed ScannerCallable which supports backward scanning.
|
(package private) class |
RpcRetryingCallable<V>
A RetryingCallable for RPC connection operations.
|
(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 |
---|---|
private RetryingCallable<T> |
ResultBoundedCompletionService.QueueingFuture.future |
Modifier and Type | Method and Description |
---|---|
private <C extends RetryingCallable<V> & Closeable,V> |
HBaseAdmin.executeCallable(C callable) |
private static <C extends RetryingCallable<V> & Closeable,V> |
HBaseAdmin.executeCallable(C callable,
RpcRetryingCallerFactory rpcCallerFactory,
int operationTimeout,
int rpcTimeout) |
Modifier and Type | Method and Description |
---|---|
T |
RpcRetryingCallerImpl.callWithoutRetries(RetryingCallable<T> callable,
int callTimeout) |
T |
RpcRetryingCaller.callWithoutRetries(RetryingCallable<T> callable,
int callTimeout)
Call the server once only.
|
T |
RpcRetryingCallerImpl.callWithRetries(RetryingCallable<T> callable,
int callTimeout) |
T |
RpcRetryingCaller.callWithRetries(RetryingCallable<T> callable,
int callTimeout)
Retries if invocation fails.
|
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. |
FastFailInterceptorContext |
FastFailInterceptorContext.prepare(RetryingCallable<?> callable) |
RetryingCallerInterceptorContext |
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable) |
abstract RetryingCallerInterceptorContext |
RetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable,
int tries)
Telescopic extension that takes which of the many retries we are currently in.
|
FastFailInterceptorContext |
FastFailInterceptorContext.prepare(RetryingCallable<?> callable,
int tries) |
RetryingCallerInterceptorContext |
NoOpRetryingInterceptorContext.prepare(RetryingCallable<?> callable,
int tries) |
void |
ResultBoundedCompletionService.submit(RetryingCallable<V> task,
int rpcTimeout,
int operationTimeout,
int id) |
Constructor and Description |
---|
QueueingFuture(RetryingCallable<T> future,
int rpcTimeout,
int operationTimeout,
int id) |
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 |
---|
RetryingRpcCallable(RpcRetryingCallerFactory factory,
RetryingCallable<V> callable,
int timeout) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.