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.
static <T> T	createRMProxy(Configuration conf, Class<T> protocol, InetSocketAddress rmAddress) Deprecated. This method is deprecated and is not used by YARN internally any more. To create a proxy to the RM, use ClientRMProxy#createRMProxy or ServerRMProxy#createRMProxy. Create a proxy to the ResourceManager at the specified address.

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

createRMProxy

@Deprecated
public static <T> T createRMProxy(Configuration conf,
                                              Class<T> protocol,
                                              InetSocketAddress rmAddress)
                                       throws IOException

Deprecated. This method is deprecated and is not used by YARN internally any more. To create a proxy to the RM, use ClientRMProxy#createRMProxy or ServerRMProxy#createRMProxy. Create a proxy to the ResourceManager at the specified address.

Type Parameters:

T - Type information of the proxy

Parameters:

conf - Configuration to generate retry policy

protocol - Protocol for the proxy

rmAddress - Address of the ResourceManager

Returns:

Proxy to the RM

Throws:

IOException

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.