Uses of Interface
org.apache.hadoop.hbase.client.RetryingCallable
Packages that use RetryingCallable
Package
Description
Provides HBase Client
-
Uses of RetryingCallable in org.apache.hadoop.hbase.client
Classes in org.apache.hadoop.hbase.client that implement RetryingCallableModifier and TypeClassDescription(package private) classThis class is used to unify HTable calls with AsyncProcess Framework.classA RegionServerCallable set to use the Client protocol.classA Callable for flushRegion() RPC.(package private) classA RetryingCallable for Master RPC operations.(package private) classCallable that handles themultimethod call going against a single regionserver; i.e.classImplementations make an rpc call against a RegionService via a protobuf Service.classSimilar to RegionServerCallable but for the AdminService interface.classRegionServerCallable<T,S> Implementations make a RPC call against a RegionService via a protobuf Service.classA reversed ScannerCallable which supports backward scanning.(package private) classA RetryingCallable for RPC connection operations.(package private) classA RegionServerCallable that takes into account the replicas, i.e.classScanner operations such as create, next, etc.(package private) classThis class has the logic for handling scanners for regions with and without replicas.(package private) classFields in org.apache.hadoop.hbase.client declared as RetryingCallableModifier and TypeFieldDescriptionprivate final RetryingCallable<T>ResultBoundedCompletionService.QueueingFuture.futureMethods in org.apache.hadoop.hbase.client with type parameters of type RetryingCallableModifier 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) Methods in org.apache.hadoop.hbase.client with parameters of type RetryingCallableModifier 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 RetryingCallerInterceptorContextRetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable) This prepares the context object by populating it with information specific to the implementation of theRetryingCallerInterceptoralong with which this will be used.abstract RetryingCallerInterceptorContextRetryingCallerInterceptorContext.prepare(RetryingCallable<?> callable, int tries) Telescopic extension that takes which of the many retries we are currently in.voidResultBoundedCompletionService.submit(RetryingCallable<V> task, int rpcTimeout, int operationTimeout, int id) Constructors in org.apache.hadoop.hbase.client with parameters of type RetryingCallableModifierConstructorDescriptionQueueingFuture(RetryingCallable<T> future, int rpcTimeout, int operationTimeout, int id) -
Uses of RetryingCallable in org.apache.hadoop.hbase.replication.regionserver
Classes in org.apache.hadoop.hbase.replication.regionserver that implement RetryingCallableModifier and TypeClassDescription(package private) static classCalls replay on the passed edits for the given set of entries belonging to the region.Fields in org.apache.hadoop.hbase.replication.regionserver declared as RetryingCallableModifier and TypeFieldDescription(package private) RetryingCallable<V>RegionReplicaReplicationEndpoint.RetryingRpcCallable.callableConstructors in org.apache.hadoop.hbase.replication.regionserver with parameters of type RetryingCallableModifierConstructorDescriptionRetryingRpcCallable(RpcRetryingCallerFactory factory, RetryingCallable<V> callable, int timeout)