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

Class PartitionQueueMetrics

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.hadoop.metrics2.MetricsSource

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

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PartitionQueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf, String partition)

Method Summary

Modifier and Type	Method	Description
QueueMetrics	getUserMetrics(String userName)	Partition * Queue * User Metrics Computes Metrics at Partition (Node Label) * Queue * User Level.

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

activateApp, addAppAttemptFirstContainerAllocationDelay, allocateResources, allocateResources, clearQueueMetrics, createQueueMetricsForCustomResources, deactivateApp, decrActiveUsers, decrPendingResources, decrReserveResource, fillInValuesFromAvailableResources, finishApp, finishAppAttempt, forQueue, 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, registerCustomResources, 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

Constructor Details

PartitionQueueMetrics

protected PartitionQueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms,
 String queueName,
 Queue parent,
 boolean enableUserMetrics,
 org.apache.hadoop.conf.Configuration conf,
 String partition)

Method Details

getUserMetrics

public QueueMetrics getUserMetrics(String userName)

Partition * Queue * User Metrics Computes Metrics at Partition (Node Label) * Queue * User Level. Sample JMX O/P Structure: PartitionQueueMetrics (labelX) QueueMetrics (A) usermetrics QueueMetrics (A1) usermetrics QueueMetrics (A2) usermetrics QueueMetrics (B) usermetrics

Overrides:

getUserMetrics in class QueueMetrics

Returns:

QueueMetrics