@InterfaceAudience.Public @InterfaceStability.Evolving public class RMProxy<T> extends Object
Modifier | Constructor and Description |
---|---|
protected |
RMProxy() |
Modifier and Type | Method and Description |
---|---|
protected static org.apache.hadoop.io.retry.RetryPolicy |
createRetryPolicy(Configuration conf,
long retryTime,
long retryInterval,
boolean isHAEnabled)
Fetch retry policy from Configuration and create the
retry policy with specified retryTime and retry interval.
|
protected static <T> T |
createRMProxyFederation(Configuration configuration,
Class<T> protocol,
RMProxy<T> instance)
This functionality is only used for NodeManager and only in non-HA mode.
|
protected static <T> org.apache.hadoop.yarn.client.RMFailoverProxyProvider<T> |
getRMFailoverProxyProvider(YarnConfiguration conf,
Class<T> protocol,
RMProxy<T> instance) |
protected static <T> T |
newProxyInstanceFederation(YarnConfiguration conf,
Class<T> protocol,
RMProxy<T> instance,
org.apache.hadoop.io.retry.RetryPolicy retryPolicy) |
protected static <T> T createRMProxyFederation(Configuration configuration, Class<T> protocol, RMProxy<T> instance) throws IOException
T
- Generic T.configuration
- configuration.protocol
- protocol.instance
- RMProxy instance.IOException
- io error occur.protected static <T> T newProxyInstanceFederation(YarnConfiguration conf, Class<T> protocol, RMProxy<T> instance, org.apache.hadoop.io.retry.RetryPolicy retryPolicy)
protected static <T> org.apache.hadoop.yarn.client.RMFailoverProxyProvider<T> getRMFailoverProxyProvider(YarnConfiguration conf, Class<T> protocol, RMProxy<T> instance)
protected static org.apache.hadoop.io.retry.RetryPolicy createRetryPolicy(Configuration conf, long retryTime, long retryInterval, boolean isHAEnabled)
conf
- configuration.retryTime
- retry time.retryInterval
- retry interval.isHAEnabled
- is HA enabled.Copyright © 2024 Apache Software Foundation. All rights reserved.