org.apache.hadoop.io.retry

类 RetryUtils

java.lang.Object

org.apache.hadoop.io.retry.RetryUtils

public class RetryUtils
extends Object

字段概要

字段

限定符和类型	字段和说明
static org.apache.commons.logging.Log	LOG

构造器概要

构造器

构造器和说明
RetryUtils()

方法概要

方法

限定符和类型	方法和说明
static RetryPolicy	getDefaultRetryPolicy(Configuration conf, String retryPolicyEnabledKey, boolean defaultRetryPolicyEnabled, String retryPolicySpecKey, String defaultRetryPolicySpec, Class<? extends Exception>... remoteExceptionsToRetry) 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.

从类继承的方法 java.lang.Object

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

字段详细资料

LOG

public static final org.apache.commons.logging.Log LOG

构造器详细资料

RetryUtils

public RetryUtils()

方法详细资料

getDefaultRetryPolicy

public static RetryPolicy getDefaultRetryPolicy(Configuration conf,
                                String retryPolicyEnabledKey,
                                boolean defaultRetryPolicyEnabled,
                                String retryPolicySpecKey,
                                String defaultRetryPolicySpec,
                                Class<? extends Exception>... remoteExceptionsToRetry)

Return the default retry policy set in conf. If the value retryPolicyEnabledKey is set to false in conf, use TRY_ONCE_THEN_FAIL. Otherwise, get the MultipleLinearRandomRetry policy specified in the conf and then (1) use multipleLinearRandomRetry for - remoteExceptionToRetry, or - IOException other than RemoteException; and (2) use TRY_ONCE_THEN_FAIL for - RemoteException other than remoteExceptionToRetry, or - non-IOException.

参数:

conf -

retryPolicyEnabledKey - conf property key for enabling retry

defaultRetryPolicyEnabled - default retryPolicyEnabledKey conf value

retryPolicySpecKey - conf property key for retry policy spec

defaultRetryPolicySpec - default retryPolicySpecKey conf value

remoteExceptionsToRetry - The particular RemoteExceptions to retry

返回:

the default retry policy.

getMultipleLinearRandomRetry

public 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. If the policy is specified in the conf but the policy cannot be parsed, the default policy is returned. Retry policy spec: N pairs of sleep-time and number-of-retries "s1,n1,s2,n2,..."

参数:

conf -

retryPolicyEnabledKey - conf property key for enabling retry

defaultRetryPolicyEnabled - default retryPolicyEnabledKey conf value

retryPolicySpecKey - conf property key for retry policy spec

defaultRetryPolicySpec - default retryPolicySpecKey conf value

返回:

the MultipleLinearRandomRetry policy specified in the conf, or null if the feature is disabled.