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

Interface SchedulerQueueManager<T extends SchedulerQueue,E extends ReservationSchedulerConfiguration>

All Known Implementing Classes:
CapacitySchedulerQueueManager
@Private @Unstable public interface SchedulerQueueManager<T extends SchedulerQueue,E extends ReservationSchedulerConfiguration>
Context of the Queues in Scheduler.

  • Method Details

    • getRootQueue

      T getRootQueue()
      Get the root queue.
      Returns:
      root queue

    • getQueues

      Map<String,T> getQueues()
      Get all the queues.
      Returns:
      a map contains all the queues as well as related queue names

    • removeQueue

      void removeQueue(String queueName)
      Remove the queue from the existing queue.
      Parameters:
      queueName - the queue name

    • addQueue

      void addQueue(String queueName, T queue)
      Add a new queue to the existing queues.
      Parameters:
      queueName - the queue name
      queue - the queue object

    • getQueue

      T getQueue(String queueName)
      Get a queue matching the specified queue name.
      Parameters:
      queueName - the queue name
      Returns:
      a queue object

    • reinitializeQueues

      void reinitializeQueues(E newConf) throws IOException
      Reinitialize the queues.
      Parameters:
      newConf - the configuration
      Throws:
      IOException - if fails to re-initialize queues