@InterfaceAudience.Private class NoOpRetryableCallerInterceptor extends RetryingCallerInterceptor
RetryingCallerInterceptor was not configured correctly or an
RetryingCallerInterceptor was never configured in the first place.| Modifier and Type | Field and Description |
|---|---|
private static RetryingCallerInterceptorContext |
NO_OP_CONTEXT |
| Constructor and Description |
|---|
NoOpRetryableCallerInterceptor() |
NoOpRetryableCallerInterceptor(org.apache.hadoop.conf.Configuration conf) |
| 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.
|
private static final RetryingCallerInterceptorContext NO_OP_CONTEXT
public NoOpRetryableCallerInterceptor()
public NoOpRetryableCallerInterceptor(org.apache.hadoop.conf.Configuration conf)
public void intercept(RetryingCallerInterceptorContext abstractRetryingCallerInterceptorContext) throws PreemptiveFastFailException
RetryingCallerInterceptorintercept in class RetryingCallerInterceptorPreemptiveFastFailExceptionpublic void handleFailure(RetryingCallerInterceptorContext context, Throwable t) throws IOException
RetryingCallerInterceptorhandleFailure in class RetryingCallerInterceptorcontext - : The context object that we obtained previously.t - : The exception that we caught in this particular tryIOExceptionpublic void updateFailureInfo(RetryingCallerInterceptorContext context)
RetryingCallerInterceptorupdateFailureInfo in class RetryingCallerInterceptorpublic RetryingCallerInterceptorContext createEmptyContext()
RetryingCallerInterceptorcreateEmptyContext in class RetryingCallerInterceptorpublic String toString()
toString in class RetryingCallerInterceptorCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.