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

Interface CapacitySchedulerPreemptionContext

All Known Implementing Classes:
ProportionalCapacityPreemptionPolicy
public interface CapacitySchedulerPreemptionContext
This interface provides context for the calculation of ideal allocation and preemption for the CapacityScheduler.

  • Method Details

    • getScheduler

      CapacityScheduler getScheduler()

    • getQueueByPartition

      TempQueuePerPartition getQueueByPartition(String queueName, String partition)

    • getQueuePartitions

      Collection<TempQueuePerPartition> getQueuePartitions(String queueName)

    • getResourceCalculator

      org.apache.hadoop.yarn.util.resource.ResourceCalculator getResourceCalculator()

    • getRMContext

      RMContext getRMContext()

    • isObserveOnly

      boolean isObserveOnly()

    • getKillableContainers

      Set<org.apache.hadoop.yarn.api.records.ContainerId> getKillableContainers()

    • getMaxIgnoreOverCapacity

      double getMaxIgnoreOverCapacity()

    • getNaturalTerminationFactor

      double getNaturalTerminationFactor()

    • getLeafQueueNames

      Set<String> getLeafQueueNames()

    • getAllPartitions

      Set<String> getAllPartitions()

    • getClusterMaxApplicationPriority

      int getClusterMaxApplicationPriority()

    • getPartitionResource

      org.apache.hadoop.yarn.api.records.Resource getPartitionResource(String partition)

    • getUnderServedQueuesPerPartition

      LinkedHashSet<String> getUnderServedQueuesPerPartition(String partition)

    • addPartitionToUnderServedQueues

      void addPartitionToUnderServedQueues(String queueName, String partition)

    • getMinimumThresholdForIntraQueuePreemption

      float getMinimumThresholdForIntraQueuePreemption()

    • getMaxAllowableLimitForIntraQueuePreemption

      float getMaxAllowableLimitForIntraQueuePreemption()

    • getDefaultMaximumKillWaitTimeout

      long getDefaultMaximumKillWaitTimeout()

    • getIntraQueuePreemptionOrderPolicy

      @Unstable ProportionalCapacityPreemptionPolicy.IntraQueuePreemptionOrderPolicy getIntraQueuePreemptionOrderPolicy()

    • getCrossQueuePreemptionConservativeDRF

      boolean getCrossQueuePreemptionConservativeDRF()

    • getInQueuePreemptionConservativeDRF

      boolean getInQueuePreemptionConservativeDRF()