public class RetryUtils extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
RetryUtils() |
Modifier and Type | Method and Description |
---|---|
static RetryPolicy |
getDefaultRetryPolicy(Configuration conf,
String retryPolicyEnabledKey,
boolean defaultRetryPolicyEnabled,
String retryPolicySpecKey,
String defaultRetryPolicySpec,
Class<? extends Exception> remoteExceptionToRetry)
Return the default retry policy set in conf.
|
static RetryPolicy |
getMultipleLinearRandomRetry(Configuration conf,
String retryPolicyEnabledKey,
boolean defaultRetryPolicyEnabled,
String retryPolicySpecKey,
String defaultRetryPolicySpec)
Return the MultipleLinearRandomRetry policy specified in the conf,
or null if the feature is disabled.
|
public static RetryPolicy getDefaultRetryPolicy(Configuration conf, String retryPolicyEnabledKey, boolean defaultRetryPolicyEnabled, String retryPolicySpecKey, String defaultRetryPolicySpec, Class<? extends Exception> remoteExceptionToRetry)
conf
- retryPolicyEnabledKey
- conf property key for enabling retrydefaultRetryPolicyEnabled
- default retryPolicyEnabledKey conf valueretryPolicySpecKey
- conf property key for retry policy specdefaultRetryPolicySpec
- default retryPolicySpecKey conf valueremoteExceptionToRetry
- The particular RemoteException to retrypublic static RetryPolicy getMultipleLinearRandomRetry(Configuration conf, String retryPolicyEnabledKey, boolean defaultRetryPolicyEnabled, String retryPolicySpecKey, String defaultRetryPolicySpec)
conf
- retryPolicyEnabledKey
- conf property key for enabling retrydefaultRetryPolicyEnabled
- default retryPolicyEnabledKey conf valueretryPolicySpecKey
- conf property key for retry policy specdefaultRetryPolicySpec
- default retryPolicySpecKey conf valueCopyright © 2013 Apache Software Foundation. All rights reserved.