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

Class CSQueueMetrics

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.hadoop.metrics2.MetricsSource

@Metrics(context="yarn")
public class CSQueueMetrics
extends QueueMetrics

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CSQueueMetrics.DummyMetricsSystemImpl

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics

conf, DEFAULT_PARTITION, DEFAULT_PARTITION_JMX_STR, METRIC_NAME_DELIMITER, metricsSystem, P_RECORD_INFO, PARTITION_INFO, QUEUE_INFO, queueName, registry, storedPartitionMetrics, USER_INFO, users

Method Summary

Modifier and Type	Method	Description
protected void	createQueueMetricsForCustomResources()
void	decAMUsed(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
static CSQueueMetrics	forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf)
float	getAbsoluteUsedCapacity()
long	getAMResourceLimitMB()
long	getAMResourceLimitVCores()
float	getGuaranteedAbsoluteCapacity()
float	getGuaranteedCapacity()
long	getGuaranteedMB()
int	getGuaranteedVCores()
float	getMaxAbsoluteCapacity()
float	getMaxCapacity()
long	getMaxCapacityMB()
int	getMaxCapacityVCores()
long	getUsedAMResourceMB()
long	getUsedAMResourceVCores()
float	getUsedCapacity()
QueueMetrics	getUserMetrics(String userName)
void	incAMUsed(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
protected void	registerCustomResources()	Register all custom resources metrics as part of initialization.
void	setAbsoluteUsedCapacity(String partition, Float absoluteUsedCap)
void	setAMResouceLimit(String partition, org.apache.hadoop.yarn.api.records.Resource res)
void	setAMResouceLimitForUser(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
void	setGuaranteedCapacities(String partition, float capacity, float absoluteCapacity)
void	setGuaranteedResources(String partition, org.apache.hadoop.yarn.api.records.Resource res)
void	setMaxCapacities(String partition, float capacity, float absoluteCapacity)
void	setMaxCapacityResources(String partition, org.apache.hadoop.yarn.api.records.Resource res)
void	setUsedCapacity(String partition, float usedCap)

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

activateApp, addAppAttemptFirstContainerAllocationDelay, allocateResources, allocateResources, clearQueueMetrics, deactivateApp, decrActiveUsers, decrPendingResources, decrReserveResource, fillInValuesFromAvailableResources, finishApp, finishAppAttempt, forQueue, getActiveApps, getActiveUsers, getAggegatedReleasedContainers, getAggregateAllocatedContainers, getAggregatedPreemptedSecondsResources, getAggregateMemoryMBPreempted, getAggregateMemoryMBSecondsPreempted, getAggregateNodeLocalContainersAllocated, getAggregateOffSwitchContainersAllocated, getAggregatePreemptedContainers, getAggregateRackLocalContainersAllocated, getAggregateVcoreSecondsPreempted, getAggregateVcoresPreempted, getAllocatedContainers, getAllocatedMB, getAllocatedResources, getAllocatedVirtualCores, getAppsCompleted, getAppsFailed, getAppsKilled, getAppsPending, getAppsRunning, getAppsSubmitted, getAvailableMB, getAvailableResources, getAvailableVirtualCores, getMetrics, getMetricsSystem, getParentQueue, getPartitionQueueMetrics, getPendingContainers, getPendingMB, getPendingResources, getPendingVirtualCores, getQueueMetrics, getQueueMetricsForCustomResources, getReservedContainers, getReservedMB, getReservedResources, getReservedVirtualCores, getUnmanagedAppsCompleted, getUnmanagedAppsFailed, getUnmanagedAppsPending, getUnmanagedAppsRunning, getUnmanagedAppsSubmitted, incrActiveUsers, incrNodeTypeAggregations, incrPendingResources, incrReserveResources, internalAllocateResources, internalDecrPendingResources, internalIncrPendingResources, internalReleaseResources, internalReserveResources, internalUnReserveResources, isConfigurationValidationSet, moveAppFrom, moveAppTo, preemptContainer, registerPartitionMetricsCreation, releaseResources, reserveResource, runAppAttempt, setAvailableResources, setAvailableResourcesToQueue, setAvailableResourcesToQueue, setAvailableResourcesToUser, setConfigurationValidation, setParent, setParentQueue, setQueueMetricsForCustomResources, sourceName, submitApp, submitAppAttempt, tag, unreserveResource, updatePreemptedForCustomResources, updatePreemptedMemoryMBSeconds, updatePreemptedResources, updatePreemptedSecondsForCustomResources, updatePreemptedVcoreSeconds

Methods inherited from class java.lang.Object

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

Method Details

registerCustomResources

protected void registerCustomResources()

Register all custom resources metrics as part of initialization. As and when this metric object construction happens for any queue, all custom resource metrics value would be initialized with '0' like any other mandatory resources metrics

Overrides:

registerCustomResources in class QueueMetrics

getAMResourceLimitMB

public long getAMResourceLimitMB()

getAMResourceLimitVCores

public long getAMResourceLimitVCores()

getUsedAMResourceMB

public long getUsedAMResourceMB()

getUsedAMResourceVCores

public long getUsedAMResourceVCores()

setAMResouceLimit

public void setAMResouceLimit(String partition,
 org.apache.hadoop.yarn.api.records.Resource res)

setAMResouceLimitForUser

public void setAMResouceLimitForUser(String partition,
 String user,
 org.apache.hadoop.yarn.api.records.Resource res)

incAMUsed

public void incAMUsed(String partition,
 String user,
 org.apache.hadoop.yarn.api.records.Resource res)

decAMUsed

public void decAMUsed(String partition,
 String user,
 org.apache.hadoop.yarn.api.records.Resource res)

getUsedCapacity

public float getUsedCapacity()

setUsedCapacity

public void setUsedCapacity(String partition,
 float usedCap)

getAbsoluteUsedCapacity

public float getAbsoluteUsedCapacity()

setAbsoluteUsedCapacity

public void setAbsoluteUsedCapacity(String partition,
 Float absoluteUsedCap)

getGuaranteedMB

public long getGuaranteedMB()

getGuaranteedVCores

public int getGuaranteedVCores()

setGuaranteedResources

public void setGuaranteedResources(String partition,
 org.apache.hadoop.yarn.api.records.Resource res)

getMaxCapacityMB

public long getMaxCapacityMB()

getMaxCapacityVCores

public int getMaxCapacityVCores()

setMaxCapacityResources

public void setMaxCapacityResources(String partition,
 org.apache.hadoop.yarn.api.records.Resource res)

createQueueMetricsForCustomResources

protected void createQueueMetricsForCustomResources()

Overrides:

createQueueMetricsForCustomResources in class QueueMetrics

forQueue

public static CSQueueMetrics forQueue(String queueName,
 Queue parent,
 boolean enableUserMetrics,
 org.apache.hadoop.conf.Configuration conf)

getUserMetrics

public QueueMetrics getUserMetrics(String userName)

Overrides:

getUserMetrics in class QueueMetrics

getGuaranteedCapacity

public float getGuaranteedCapacity()

getGuaranteedAbsoluteCapacity

public float getGuaranteedAbsoluteCapacity()

setGuaranteedCapacities

public void setGuaranteedCapacities(String partition,
 float capacity,
 float absoluteCapacity)

getMaxCapacity

public float getMaxCapacity()

getMaxAbsoluteCapacity

public float getMaxAbsoluteCapacity()

setMaxCapacities

public void setMaxCapacities(String partition,
 float capacity,
 float absoluteCapacity)