Package org.apache.hadoop.yarn.server.resourcemanager

Class NodesListManager.CachedResolver

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.resourcemanager.NodesListManager.CachedResolver
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service, NodesListManager.Resolver
Enclosing class:
NodesListManager
@VisibleForTesting public static class NodesListManager.CachedResolver extends org.apache.hadoop.service.AbstractService implements NodesListManager.Resolver

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

    org.apache.hadoop.service.Service.STATE

  • Constructor Summary

    Constructors
    Constructor
    Description
    CachedResolver(org.apache.hadoop.yarn.util.Clock clock, int expiryIntervalSecs)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addToCache(String hostName, String ip)
     
    TimerTask
    getExpireChecker()
     
    void
    removeFromCache(String hostName)
     
    String
    resolve(String hostName)
     
    protected void
    serviceStart()
     
    protected void
    serviceStop()
     

    Methods inherited from class org.apache.hadoop.service.AbstractService

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • CachedResolver

      public CachedResolver(org.apache.hadoop.yarn.util.Clock clock, int expiryIntervalSecs)

  • Method Details

    • serviceStart

      protected void serviceStart() throws Exception
      Overrides:
      serviceStart in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStop

      protected void serviceStop() throws Exception
      Overrides:
      serviceStop in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • addToCache

      @VisibleForTesting public void addToCache(String hostName, String ip)

    • removeFromCache

      public void removeFromCache(String hostName)

    • resolve

      public String resolve(String hostName)
      Specified by:
      resolve in interface NodesListManager.Resolver

    • getExpireChecker

      @VisibleForTesting public TimerTask getExpireChecker()