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

Class CSQueueUtils

java.lang.Object

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

public class CSQueueUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final float	EPSILON

Constructor Summary

Constructors

Constructor	Description
CSQueueUtils()

Method Summary

Modifier and Type	Method	Description
static void	checkAbsoluteCapacity(QueuePath queuePath, float absCapacity, float absMaxCapacity)
static void	checkMaxCapacity(QueuePath queuePath, float capacity, float maximumCapacity)
static float	computeAbsoluteMaximumCapacity(float maximumCapacity, CSQueue parent)
static void	loadCapacitiesByLabelsFromConf(QueuePath queuePath, QueueCapacities queueCapacities, CapacitySchedulerConfiguration csConf, Set<String> nodeLabels)
static void	updateAbsoluteCapacitiesByNodeLabels(QueueCapacities queueCapacities, QueueCapacities parentQueueCapacities, Set<String> nodeLabels, boolean isLegacyQueueMode)
static void	updateConfiguredCapacityMetrics(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource partitionResource, String partition, AbstractCSQueue queue)	Updated configured capacity/max-capacity for queue.
static void	updateQueueStatistics(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource cluster, AbstractCSQueue childQueue, RMNodeLabelsManager nlm, String nodePartition)	Update Queue Statistics:
static void	updateUsedCapacity(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource totalPartitionResource, String nodePartition, AbstractCSQueue childQueue)	Update partitioned resource usage, if nodePartition == null, will update used resource for all partitions of this queue.

Methods inherited from class java.lang.Object

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

Field Details

EPSILON

public static final float EPSILON

See Also:

• Constant Field Values

Constructor Details

CSQueueUtils

public CSQueueUtils()

Method Details

checkMaxCapacity

public static void checkMaxCapacity(QueuePath queuePath,
 float capacity,
 float maximumCapacity)

checkAbsoluteCapacity

public static void checkAbsoluteCapacity(QueuePath queuePath,
 float absCapacity,
 float absMaxCapacity)

computeAbsoluteMaximumCapacity

public static float computeAbsoluteMaximumCapacity(float maximumCapacity,
 CSQueue parent)

loadCapacitiesByLabelsFromConf

public static void loadCapacitiesByLabelsFromConf(QueuePath queuePath,
 QueueCapacities queueCapacities,
 CapacitySchedulerConfiguration csConf,
 Set<String> nodeLabels)

updateUsedCapacity

public static void updateUsedCapacity(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
 org.apache.hadoop.yarn.api.records.Resource totalPartitionResource,
 String nodePartition,
 AbstractCSQueue childQueue)

Update partitioned resource usage, if nodePartition == null, will update used resource for all partitions of this queue.

Parameters:

rc - resource calculator.

totalPartitionResource - total Partition Resource.

nodePartition - node label.

childQueue - child queue.

updateQueueStatistics

@Lock(CSQueue.class)
public static void updateQueueStatistics(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
 org.apache.hadoop.yarn.api.records.Resource cluster,
 AbstractCSQueue childQueue,
 RMNodeLabelsManager nlm,
 String nodePartition)

Update Queue Statistics:

• used-capacity/absolute-used-capacity by partition
• non-partitioned max-avail-resource to queue

When nodePartition is null, all partition of used-capacity/absolute-used-capacity will be updated.

Parameters:

rc - resource calculator.

cluster - cluster resource.

childQueue - child queue.

nlm - RMNodeLabelsManager.

nodePartition - node label.

updateConfiguredCapacityMetrics

public static void updateConfiguredCapacityMetrics(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
 org.apache.hadoop.yarn.api.records.Resource partitionResource,
 String partition,
 AbstractCSQueue queue)

Updated configured capacity/max-capacity for queue.

Parameters:

rc - resource calculator

partitionResource - total cluster resources for this partition

partition - partition being updated

queue - queue

updateAbsoluteCapacitiesByNodeLabels

public static void updateAbsoluteCapacitiesByNodeLabels(QueueCapacities queueCapacities,
 QueueCapacities parentQueueCapacities,
 Set<String> nodeLabels,
 boolean isLegacyQueueMode)