org.apache.hadoop.yarn.client
Class ClientRMProxy<T>

java.lang.Object
  org.apache.hadoop.yarn.client.RMProxy<T>
      org.apache.hadoop.yarn.client.ClientRMProxy<T>

@InterfaceAudience.Public
@InterfaceStability.Stable
public class ClientRMProxy<T>
extends RMProxy<T>

Method Summary

static <T> T	createRMProxy(Configuration configuration, Class<T> protocol) Create a proxy to the ResourceManager for the specified protocol.
static Text	getRMDelegationTokenService(Configuration conf) Get the token service name to be used for RMDelegationToken.

Methods inherited from class org.apache.hadoop.yarn.client.RMProxy

createRMProxy

Methods inherited from class java.lang.Object

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

Method Detail

createRMProxy

public static <T> T createRMProxy(Configuration configuration,
                                  Class<T> protocol)
                       throws IOException

Create a proxy to the ResourceManager for the specified protocol.

Type Parameters:

T - Type of proxy.

Parameters:

configuration - Configuration with all the required information.

protocol - Client protocol for which proxy is being requested.

Returns:

Proxy to the ResourceManager for the specified client protocol.

Throws:

IOException

getRMDelegationTokenService

@InterfaceStability.Unstable
public static Text getRMDelegationTokenService(Configuration conf)

Get the token service name to be used for RMDelegationToken. Depending on whether HA is enabled or not, this method generates the appropriate service name as a comma-separated list of service addresses.

Parameters:

conf - Configuration corresponding to the cluster we need the RMDelegationToken for

Returns:

- Service name for RMDelegationToken