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

Class WeightQueueCapacityCalculator

java.lang.Object

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

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

public class WeightQueueCapacityCalculator
extends AbstractQueueCapacityCalculator

Constructor Summary

Constructors

Constructor	Description
WeightQueueCapacityCalculator()

Method Summary

Modifier and Type	Method	Description
double	calculateMaximumResource(ResourceCalculationDriver resourceCalculationDriver, CalculationContext context, String label)	Calculates the maximum effective resource.
double	calculateMinimumResource(ResourceCalculationDriver resourceCalculationDriver, CalculationContext context, String label)	Calculates the minimum effective resource.
void	calculateResourcePrerequisites(ResourceCalculationDriver resourceCalculationDriver)	Executes all logic that must be called prior to the effective resource value calculations.
QueueCapacityVector.ResourceUnitCapacityType	getCapacityType()	Returns the capacity type the calculator could handle.
void	updateCapacitiesAfterCalculation(ResourceCalculationDriver resourceCalculationDriver, CSQueue queue, String label)	Sets the metrics and statistics after effective resource values calculation.

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractQueueCapacityCalculator

getResourceNames, getResourceNames

Methods inherited from class java.lang.Object

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

Constructor Details

WeightQueueCapacityCalculator

public WeightQueueCapacityCalculator()

Method Details

calculateResourcePrerequisites

public void calculateResourcePrerequisites(ResourceCalculationDriver resourceCalculationDriver)

Description copied from class: AbstractQueueCapacityCalculator

Executes all logic that must be called prior to the effective resource value calculations.

Specified by:

calculateResourcePrerequisites in class AbstractQueueCapacityCalculator

Parameters:

resourceCalculationDriver - driver that contains the parent queue on which the prerequisite calculation should be made

calculateMinimumResource

public double calculateMinimumResource(ResourceCalculationDriver resourceCalculationDriver,
 CalculationContext context,
 String label)

Description copied from class: AbstractQueueCapacityCalculator

Calculates the minimum effective resource.

Specified by:

calculateMinimumResource in class AbstractQueueCapacityCalculator

Parameters:

resourceCalculationDriver - driver that contains the intermediate calculation results for a queue branch

context - the units evaluated in the current iteration phase

label - node label

Returns:

minimum effective resource

calculateMaximumResource

public double calculateMaximumResource(ResourceCalculationDriver resourceCalculationDriver,
 CalculationContext context,
 String label)

Description copied from class: AbstractQueueCapacityCalculator

Calculates the maximum effective resource.

Specified by:

calculateMaximumResource in class AbstractQueueCapacityCalculator

Parameters:

resourceCalculationDriver - driver that contains the intermediate calculation results for a queue branch

context - the units evaluated in the current iteration phase

label - node label

Returns:

minimum effective resource

getCapacityType

public QueueCapacityVector.ResourceUnitCapacityType getCapacityType()

Description copied from class: AbstractQueueCapacityCalculator

Returns the capacity type the calculator could handle.

Specified by:

getCapacityType in class AbstractQueueCapacityCalculator

Returns:

capacity type

updateCapacitiesAfterCalculation

public void updateCapacitiesAfterCalculation(ResourceCalculationDriver resourceCalculationDriver,
 CSQueue queue,
 String label)

Description copied from class: AbstractQueueCapacityCalculator

Sets the metrics and statistics after effective resource values calculation.

Specified by:

updateCapacitiesAfterCalculation in class AbstractQueueCapacityCalculator

Parameters:

resourceCalculationDriver - driver that contains the intermediate calculation results for a queue branch

queue - the queue on which the calculations are based

label - node label