public class ConfiguredFailoverProxyProvider<T>
extends java.lang.Object
implements org.apache.hadoop.io.retry.FailoverProxyProvider<T>
Constructor and Description |
---|
ConfiguredFailoverProxyProvider(org.apache.hadoop.conf.Configuration conf,
java.lang.String jtAddress,
java.lang.Class<T> xface) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close all the proxy objects which have been opened over the lifetime of
this proxy provider.
|
java.lang.Class<T> |
getInterface() |
org.apache.hadoop.io.retry.FailoverProxyProvider.ProxyInfo<T> |
getProxy()
Lazily initialize the RPC proxy object.
|
void |
performFailover(T currentProxy) |
public ConfiguredFailoverProxyProvider(org.apache.hadoop.conf.Configuration conf, java.lang.String jtAddress, java.lang.Class<T> xface)
public java.lang.Class<T> getInterface()
getInterface
in interface org.apache.hadoop.io.retry.FailoverProxyProvider<T>
public org.apache.hadoop.io.retry.FailoverProxyProvider.ProxyInfo<T> getProxy()
getProxy
in interface org.apache.hadoop.io.retry.FailoverProxyProvider<T>
public void performFailover(T currentProxy)
performFailover
in interface org.apache.hadoop.io.retry.FailoverProxyProvider<T>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
Copyright © 2009 The Apache Software Foundation