Class RouterObserverReadConfiguredFailoverProxyProvider<T>
java.lang.Object
org.apache.hadoop.hdfs.server.namenode.ha.AbstractNNFailoverProxyProvider<T>
org.apache.hadoop.hdfs.server.namenode.ha.RouterObserverReadProxyProvider<T>
org.apache.hadoop.hdfs.server.namenode.ha.RouterObserverReadConfiguredFailoverProxyProvider<T>
- All Implemented Interfaces:
Closeable,AutoCloseable,org.apache.hadoop.io.retry.FailoverProxyProvider<T>
public class RouterObserverReadConfiguredFailoverProxyProvider<T>
extends RouterObserverReadProxyProvider<T>
A
FailoverProxyProvider implementation
to support automatic msync-ing when using routers.
This constructs a wrapper proxy of ConfiguredFailoverProxyProvider, and allows to configure logical names for nameservices.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.server.namenode.ha.AbstractNNFailoverProxyProvider
AbstractNNFailoverProxyProvider.NNProxyInfo<T>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 inherited from class org.apache.hadoop.hdfs.server.namenode.ha.AbstractNNFailoverProxyProvider
conf, factory, fallbackToSimpleAuth, ugi, xface -
Constructor Summary
ConstructorsConstructorDescriptionRouterObserverReadConfiguredFailoverProxyProvider(org.apache.hadoop.conf.Configuration conf, URI uri, Class<T> xface, HAProxyFactory<T> factory) -
Method Summary
Methods inherited from class org.apache.hadoop.hdfs.server.namenode.ha.RouterObserverReadProxyProvider
close, getAlignmentContext, getProxy, performFailover, useLogicalURIMethods inherited from class org.apache.hadoop.hdfs.server.namenode.ha.AbstractNNFailoverProxyProvider
createProxyIfNeeded, getFallbackToSimpleAuth, getInterface, getProxyAddresses, getRandomOrder, setFallbackToSimpleAuth
-
Constructor Details
-
RouterObserverReadConfiguredFailoverProxyProvider
public RouterObserverReadConfiguredFailoverProxyProvider(org.apache.hadoop.conf.Configuration conf, URI uri, Class<T> xface, HAProxyFactory<T> factory)
-