| 程序包 | 说明 |
|---|---|
| org.apache.hadoop.io.retry |
A mechanism for selectively retrying methods that throw exceptions under certain circumstances.
|
| org.apache.hadoop.ipc |
Tools to help define network clients and servers.
|
| org.apache.hadoop.tools.distcp2.util |
| 限定符和类型 | 类和说明 |
|---|---|
static class |
RetryPolicies.MultipleLinearRandomRetry
Given pairs of number of retries and sleep time (n0, t0), (n1, t1), ...,
the first n0 retries sleep t0 milliseconds on average,
the following n1 retries sleep t1 milliseconds on average, and so on.
|
| 限定符和类型 | 字段和说明 |
|---|---|
static RetryPolicy |
RetryPolicies.RETRY_FOREVER
Keep trying forever.
|
static RetryPolicy |
RetryPolicies.TRY_ONCE_DONT_FAIL
Try once, and fail silently for
void methods, or by
re-throwing the exception for non-void methods. |
static RetryPolicy |
RetryPolicies.TRY_ONCE_THEN_FAIL
Try once, and fail by re-throwing the exception.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static RetryPolicy |
RetryPolicies.exponentialBackoffRetry(int maxRetries,
long sleepTime,
TimeUnit timeUnit)
Keep trying a limited number of times, waiting a growing amount of time between attempts,
and then fail by re-throwing the exception.
|
static RetryPolicy |
RetryUtils.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 |
RetryUtils.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.
|
static RetryPolicy |
RetryPolicies.retryByException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
Set a default policy with some explicit handlers for specific exceptions.
|
static RetryPolicy |
RetryPolicies.retryByRemoteException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
A retry policy for RemoteException
Set a default policy with some explicit handlers for specific exceptions.
|
static RetryPolicy |
RetryPolicies.retryUpToMaximumCountWithFixedSleep(int maxRetries,
long sleepTime,
TimeUnit timeUnit)
Keep trying a limited number of times, waiting a fixed time between attempts,
and then fail by re-throwing the exception.
|
static RetryPolicy |
RetryPolicies.retryUpToMaximumCountWithProportionalSleep(int maxRetries,
long sleepTime,
TimeUnit timeUnit)
Keep trying a limited number of times, waiting a growing amount of time between attempts,
and then fail by re-throwing the exception.
|
static RetryPolicy |
RetryPolicies.retryUpToMaximumTimeWithFixedSleep(long maxTime,
long sleepTime,
TimeUnit timeUnit)
Keep trying for a maximum time, waiting a fixed time between attempts,
and then fail by re-throwing the exception.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static Object |
RetryProxy.create(Class<?> iface,
Object implementation,
RetryPolicy retryPolicy)
Create a proxy for an interface of an implementation class
using the same retry policy for each method in the interface.
|
static Object |
RetryProxy.create(Class<?> iface,
Object implementation,
RetryPolicy defaultPolicy,
Map<String,RetryPolicy> methodNameToPolicyMap) |
static RetryPolicy |
RetryPolicies.retryByException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
Set a default policy with some explicit handlers for specific exceptions.
|
static RetryPolicy |
RetryPolicies.retryByRemoteException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
A retry policy for RemoteException
Set a default policy with some explicit handlers for specific exceptions.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static Object |
RetryProxy.create(Class<?> iface,
Object implementation,
Map<String,RetryPolicy> methodNameToPolicyMap)
Create a proxy for an interface of an implementation class
using the a set of retry policies specified by method name.
|
static Object |
RetryProxy.create(Class<?> iface,
Object implementation,
RetryPolicy defaultPolicy,
Map<String,RetryPolicy> methodNameToPolicyMap) |
static RetryPolicy |
RetryPolicies.retryByException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
Set a default policy with some explicit handlers for specific exceptions.
|
static RetryPolicy |
RetryPolicies.retryByRemoteException(RetryPolicy defaultPolicy,
Map<Class<? extends Exception>,RetryPolicy> exceptionToPolicyMap)
A retry policy for RemoteException
Set a default policy with some explicit handlers for specific exceptions.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static VersionedProtocol |
RPC.getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
boolean checkVersion)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
| 限定符和类型 | 方法和说明 |
|---|---|
RetriableCommand |
RetriableCommand.setRetryPolicy(RetryPolicy retryHandler)
Fluent-interface to change the RetryHandler.
|
| 构造器和说明 |
|---|
RetriableCommand(String description,
RetryPolicy retryPolicy)
Constructor.
|
Copyright © 2009 The Apache Software Foundation