org.apache.hadoop.hbase.client

Class NoOpRetryableCallerInterceptor

java.lang.Object

org.apache.hadoop.hbase.client.RetryingCallerInterceptor

org.apache.hadoop.hbase.client.NoOpRetryableCallerInterceptor

@InterfaceAudience.Private
class NoOpRetryableCallerInterceptor
extends RetryingCallerInterceptor

Class that acts as a NoOpInterceptor. This class is used in case the RetryingCallerInterceptor was not configured correctly or an RetryingCallerInterceptor was never configured in the first place.

Field Summary

Fields

Modifier and Type	Field and Description
private static RetryingCallerInterceptorContext	NO_OP_CONTEXT

Constructor Summary

Constructors

Constructor and Description
NoOpRetryableCallerInterceptor()
NoOpRetryableCallerInterceptor(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
RetryingCallerInterceptorContext	createEmptyContext() This returns the context object for the current call.
void	handleFailure(RetryingCallerInterceptorContext context, Throwable t) Call this function in case we caught a failure during retries.
void	intercept(RetryingCallerInterceptorContext abstractRetryingCallerInterceptorContext) Call this function alongside the actual call done on the callable.
String	toString()
void	updateFailureInfo(RetryingCallerInterceptorContext context) Call this function to update at the end of the retry.

Methods inherited from class java.lang.Object

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

Field Detail

NO_OP_CONTEXT

private static final RetryingCallerInterceptorContext NO_OP_CONTEXT

Constructor Detail

NoOpRetryableCallerInterceptor

public NoOpRetryableCallerInterceptor()

NoOpRetryableCallerInterceptor

public NoOpRetryableCallerInterceptor(org.apache.hadoop.conf.Configuration conf)

Method Detail

intercept

public void intercept(RetryingCallerInterceptorContext abstractRetryingCallerInterceptorContext)
               throws PreemptiveFastFailException

Description copied from class: RetryingCallerInterceptor

Call this function alongside the actual call done on the callable. nn

Specified by:

intercept in class RetryingCallerInterceptor

Throws:

PreemptiveFastFailException

handleFailure

public void handleFailure(RetryingCallerInterceptorContext context,
                          Throwable t)
                   throws IOException

Description copied from class: RetryingCallerInterceptor

Call this function in case we caught a failure during retries. n * : The context object that we obtained previously. n * : The exception that we caught in this particular try n

Specified by:

handleFailure in class RetryingCallerInterceptor

Throws:

IOException

updateFailureInfo

public void updateFailureInfo(RetryingCallerInterceptorContext context)

Description copied from class: RetryingCallerInterceptor

Call this function to update at the end of the retry. This is not necessary to happen. n

Specified by:

updateFailureInfo in class RetryingCallerInterceptor

createEmptyContext

public RetryingCallerInterceptorContext createEmptyContext()

Description copied from class: RetryingCallerInterceptor

This returns the context object for the current call.

Specified by:

createEmptyContext in class RetryingCallerInterceptor

Returns:

context : the context that needs to be used during this call.

toString

public String toString()

Specified by:

toString in class RetryingCallerInterceptor