@InterfaceAudience.Private class NoOpRetryableCallerInterceptor extends RetryingCallerInterceptor
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
RetryingCallerInterceptor
intercept
in class RetryingCallerInterceptor
PreemptiveFastFailException
public void handleFailure(RetryingCallerInterceptorContext context, Throwable t) throws IOException
RetryingCallerInterceptor
handleFailure
in class RetryingCallerInterceptor
context
- : The context object that we obtained previously.t
- : The exception that we caught in this particular tryIOException
public void updateFailureInfo(RetryingCallerInterceptorContext context)
RetryingCallerInterceptor
updateFailureInfo
in class RetryingCallerInterceptor
public RetryingCallerInterceptorContext createEmptyContext()
RetryingCallerInterceptor
createEmptyContext
in class RetryingCallerInterceptor
public String toString()
toString
in class RetryingCallerInterceptor
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.