Class SchedulerConfigCache<T>

java.lang.Object
org.apache.storm.scheduler.utils.SchedulerConfigCache<T>

public class SchedulerConfigCache<T> extends Object
A utility class to cache the scheduler config and refresh after the cache expires.
  • Constructor Details

  • Method Details

    • prepare

      public void prepare()
    • refresh

      public void refresh()
      Refresh the config only after the cache expires. This is not thread-safe and should only be called in single thread.
    • get

      public T get()
      Get the scheduler config from cache. This method is thead-safe and can be called in multiple threads.
      Returns:
      the scheduler config