org.apache.hadoop.hbase.client

Class RetryingCallerInterceptorContext

java.lang.Object

org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext

Direct Known Subclasses:

FastFailInterceptorContext, NoOpRetryingInterceptorContext

@InterfaceAudience.Private
abstract class RetryingCallerInterceptorContext
extends Object

The context object used in the RpcRetryingCaller to enable RetryingCallerInterceptor to intercept calls. RetryingCallerInterceptorContext is the piece of information unique to a retrying call that transfers information from the call into the RetryingCallerInterceptor so that RetryingCallerInterceptor can take appropriate action according to the specific logic

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RetryingCallerInterceptorContext()

Method Summary

Modifier and Type	Method and Description
abstract void	clear() This function clears the internal state of the context object.
abstract 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.
abstract RetryingCallerInterceptorContext	prepare(RetryingCallable<?> callable, int tries) Telescopic extension that takes which of the many retries we are currently in.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryingCallerInterceptorContext

protected RetryingCallerInterceptorContext()

Method Detail

clear

public abstract void clear()

This function clears the internal state of the context object.

prepare

public abstract 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. n * : The RetryingCallable that contains the information about the call that is being made.

Returns:

A new RetryingCallerInterceptorContext object that can be used for use in the current retrying call

prepare

public abstract RetryingCallerInterceptorContext prepare(RetryingCallable<?> callable,
                                                         int tries)

Telescopic extension that takes which of the many retries we are currently in. n * : The RetryingCallable that contains the information about the call that is being made. n * : The retry number that we are currently in.

Returns:

A new context object that can be used for use in the current retrying call