org.apache.hadoop.yarn.client

Class AutoRefreshRMFailoverProxyProvider<T>

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.io.retry.FailoverProxyProvider<T>, RMFailoverProxyProvider<T>

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public class AutoRefreshRMFailoverProxyProvider<T>
extends ConfiguredRMFailoverProxyProvider<T>

A subclass of RMFailoverProxyProvider which tries to resolve the proxy DNS in the event of failover. This provider supports YARN Resourcemanager's HA mode. This provider doesn't support Federation.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.io.retry.FailoverProxyProvider

org.apache.hadoop.io.retry.FailoverProxyProvider.ProxyInfo<T>

Field Summary

Fields inherited from class org.apache.hadoop.yarn.client.ConfiguredRMFailoverProxyProvider

conf, protocol, rmProxy, rmServiceIds

Constructor Summary

Constructors

Constructor and Description
AutoRefreshRMFailoverProxyProvider()

Method Summary

Modifier and Type	Method and Description
void	performFailover(T currentProxy)

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

close, getInterface, getProxy, getProxyInternal, init

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoRefreshRMFailoverProxyProvider

public AutoRefreshRMFailoverProxyProvider()

Method Detail

performFailover

public void performFailover(T currentProxy)

Specified by:

performFailover in interface org.apache.hadoop.io.retry.FailoverProxyProvider<T>

Overrides:

performFailover in class ConfiguredRMFailoverProxyProvider<T>