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

Class AutoCreatedQueueDeletionPolicy

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AutoCreatedQueueDeletionPolicy
All Implemented Interfaces:
SchedulingEditPolicy
public class AutoCreatedQueueDeletionPolicy extends Object implements SchedulingEditPolicy
Auto deletion policy for auto created queue V2. Just for weight based auto created queues.

  • Constructor Details

    • AutoCreatedQueueDeletionPolicy

      public AutoCreatedQueueDeletionPolicy()

  • Method Details

    • init

      public void init(org.apache.hadoop.conf.Configuration config, RMContext context, ResourceScheduler sched)
      Specified by:
      init in interface SchedulingEditPolicy

    • prepareForAutoDeletion

      public void prepareForAutoDeletion()

    • editSchedule

      public void editSchedule()
      Description copied from interface: SchedulingEditPolicy
      This method is invoked at regular intervals. Internally the policy is allowed to track containers and affect the scheduler. The "actions" performed are passed back through an EventHandler.
      Specified by:
      editSchedule in interface SchedulingEditPolicy

    • triggerAutoDeletionForExpiredQueues

      public void triggerAutoDeletionForExpiredQueues()

    • getMonitoringInterval

      public long getMonitoringInterval()
      Specified by:
      getMonitoringInterval in interface SchedulingEditPolicy

    • getPolicyName

      public String getPolicyName()
      Specified by:
      getPolicyName in interface SchedulingEditPolicy

    • getMarkedForDeletion

      @VisibleForTesting public Set<String> getMarkedForDeletion()

    • getSentForDeletion

      @VisibleForTesting public Set<String> getSentForDeletion()