Package 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:

AutoRefreshRMFailoverProxyProvider, RequestHedgingRMFailoverProxyProvider

@Private
@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 extends Object>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ConfiguredRMFailoverProxyProvider()

Method Summary

Modifier and Type	Method	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 Details

rmProxy

protected RMProxy<T> rmProxy

protocol

protected Class<T> protocol

conf

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

rmServiceIds

protected String[] rmServiceIds

Constructor Details

ConfiguredRMFailoverProxyProvider

public ConfiguredRMFailoverProxyProvider()

Method Details

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 AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException