org.apache.hadoop.yarn.client

Class ConfiguredRMFailoverProxyProvider<T>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

RequestHedgingRMFailoverProxyProvider

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class ConfiguredRMFailoverProxyProvider<T>
extends Object
implements RMFailoverProxyProvider<T>

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

Modifier and Type	Field and Description
protected org.apache.hadoop.yarn.conf.YarnConfiguration	conf
protected Class<T>	protocol
protected RMProxy<T>	rmProxy
protected String[]	rmServiceIds

Constructor Summary

Constructors

Constructor and Description
ConfiguredRMFailoverProxyProvider()

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close all the proxy objects which have been opened over the lifetime of this proxy provider.
Class<T>	getInterface()
org.apache.hadoop.io.retry.FailoverProxyProvider.ProxyInfo<T>	getProxy()
protected T	getProxyInternal()
void	init(org.apache.hadoop.conf.Configuration configuration, RMProxy<T> rmProxy, Class<T> protocol) Initialize internal data structures, invoked right after instantiation.
void	performFailover(T currentProxy)

Methods inherited from class java.lang.Object

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

Field Detail

rmProxy

protected RMProxy<T> rmProxy

protocol

protected Class<T> protocol

conf

protected org.apache.hadoop.yarn.conf.YarnConfiguration conf

rmServiceIds

protected String[] rmServiceIds

Constructor Detail

ConfiguredRMFailoverProxyProvider

public ConfiguredRMFailoverProxyProvider()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration configuration,
        RMProxy<T> rmProxy,
        Class<T> protocol)

Description copied from interface: RMFailoverProxyProvider

Initialize internal data structures, invoked right after instantiation.

Specified by:

init in interface RMFailoverProxyProvider<T>

Parameters:

configuration - Configuration to use

rmProxy - The RMProxy instance to use

protocol - The communication protocol to use

getProxyInternal

protected T getProxyInternal()

getProxy

public org.apache.hadoop.io.retry.FailoverProxyProvider.ProxyInfo<T> getProxy()

Specified by:

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

performFailover

public void performFailover(T currentProxy)

Specified by:

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

getInterface

public Class<T> getInterface()

Specified by:

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

close

public void close()
           throws IOException

Close all the proxy objects which have been opened over the lifetime of this proxy provider.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException