org.apache.hadoop.yarn.client

Class RMProxy<T>

java.lang.Object

org.apache.hadoop.yarn.client.RMProxy<T>

Direct Known Subclasses:

ClientRMProxy

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class RMProxy<T>
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RMProxy()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMProxy

protected RMProxy()

Method Detail

createRMProxyFederation

protected static <T> T createRMProxyFederation(Configuration configuration,
                                               Class<T> protocol,
                                               RMProxy<T> instance)
                                        throws IOException

This functionality is only used for NodeManager and only in non-HA mode. Its purpose is to ensure that when initializes UAM, it can find the correct cluster.

Type Parameters:

T - Generic T.

Parameters:

configuration - configuration.

protocol - protocol.

instance - RMProxy instance.

Returns:

RMProxy.

Throws:

IOException - io error occur.

newProxyInstanceFederation

protected static <T> T newProxyInstanceFederation(YarnConfiguration conf,
                                                  Class<T> protocol,
                                                  RMProxy<T> instance,
                                                  org.apache.hadoop.io.retry.RetryPolicy retryPolicy)

getRMFailoverProxyProvider

protected static <T> org.apache.hadoop.yarn.client.RMFailoverProxyProvider<T> getRMFailoverProxyProvider(YarnConfiguration conf,
                                                                                                         Class<T> protocol,
                                                                                                         RMProxy<T> instance)

createRetryPolicy

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.

Parameters:

conf - configuration.

retryTime - retry time.

retryInterval - retry interval.

isHAEnabled - is HA enabled.

Returns:

RetryPolicy.