Uses of Interface
org.apache.hadoop.hbase.client.RetryingCallable
Package
Description
Provides HBase Client
-
Uses of RetryingCallable in org.apache.hadoop.hbase.client
Modifier and TypeClassDescription(package private) class
This class is used to unify HTable calls with AsyncProcess Framework.class
A RegionServerCallable set to use the Client protocol.class
A Callable for flushRegion() RPC.(package private) class
A RetryingCallable for Master RPC operations.(package private) class
Callable that handles themulti
method call going against a single regionserver; i.e.class
Implementations make an rpc call against a RegionService via a protobuf Service.class
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
A reversed ScannerCallable which supports backward scanning.(package private) class
A RetryingCallable for RPC connection operations.(package private) class
A RegionServerCallable that takes into account the replicas, i.e.class
Scanner operations such as create, next, etc.(package private) class
This class has the logic for handling scanners for regions with and without replicas.(package private) class
Modifier and TypeFieldDescriptionprivate final RetryingCallable<T>
ResultBoundedCompletionService.QueueingFuture.future
Modifier and TypeMethodDescriptionprivate <C extends RetryingCallable<V> & Closeable,
V>
VHBaseAdmin.executeCallable
(C callable) private static <C extends RetryingCallable<V> & Closeable,
V>
VHBaseAdmin.executeCallable
(C callable, RpcRetryingCallerFactory rpcCallerFactory, int operationTimeout, int rpcTimeout) Modifier and TypeMethodDescriptionRpcRetryingCaller.callWithoutRetries
(RetryingCallable<T> callable, int callTimeout) Call the server once only.RpcRetryingCallerImpl.callWithoutRetries
(RetryingCallable<T> callable, int callTimeout) RpcRetryingCaller.callWithRetries
(RetryingCallable<T> callable, int callTimeout) Retries if invocation fails.RpcRetryingCallerImpl.callWithRetries
(RetryingCallable<T> callable, int callTimeout) FastFailInterceptorContext.prepare
(RetryingCallable<?> callable) FastFailInterceptorContext.prepare
(RetryingCallable<?> callable, int tries) NoOpRetryingInterceptorContext.prepare
(RetryingCallable<?> callable) NoOpRetryingInterceptorContext.prepare
(RetryingCallable<?> callable, int tries) abstract RetryingCallerInterceptorContext
RetryingCallerInterceptorContext.prepare
(RetryingCallable<?> callable) This prepares the context object by populating it with information specific to the implementation of theRetryingCallerInterceptor
along with which this will be used.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 rpcTimeout, int operationTimeout, int id) ModifierConstructorDescriptionQueueingFuture
(RetryingCallable<T> future, int rpcTimeout, int operationTimeout, int id) -
Uses of RetryingCallable in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeClassDescription(package private) static class
Calls replay on the passed edits for the given set of entries belonging to the region.Modifier and TypeFieldDescription(package private) RetryingCallable<V>
RegionReplicaReplicationEndpoint.RetryingRpcCallable.callable
ModifierConstructorDescriptionRetryingRpcCallable
(RpcRetryingCallerFactory factory, RetryingCallable<V> callable, int timeout)