Interface RMFailoverProxyProvider<T>

All Superinterfaces:
AutoCloseable, Closeable, org.apache.hadoop.io.retry.FailoverProxyProvider<T>
All Known Implementing Classes:
AutoRefreshNoHARMFailoverProxyProvider, AutoRefreshRMFailoverProxyProvider, ConfiguredRMFailoverProxyProvider, DefaultNoHARMFailoverProxyProvider, RequestHedgingRMFailoverProxyProvider

@Private public interface RMFailoverProxyProvider<T> extends org.apache.hadoop.io.retry.FailoverProxyProvider<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>
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    init(org.apache.hadoop.conf.Configuration conf, RMProxy<T> proxy, Class<T> protocol)
    Initialize internal data structures, invoked right after instantiation.

    Methods inherited from interface java.io.Closeable

    close

    Methods inherited from interface org.apache.hadoop.io.retry.FailoverProxyProvider

    getInterface, getProxy, performFailover
  • Method Details

    • init

      void init(org.apache.hadoop.conf.Configuration conf, RMProxy<T> proxy, Class<T> protocol)
      Initialize internal data structures, invoked right after instantiation.
      Parameters:
      conf - Configuration to use
      proxy - The RMProxy instance to use
      protocol - The communication protocol to use