@Metrics(context="yarn") public class CSQueueMetrics extends QueueMetrics
conf, metricsSystem, parent, QUEUE_INFO, queueMetrics, queueName, registry, USER_INFO, users
Modifier and Type | Method and Description |
---|---|
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) |
long |
getAMResourceLimitMB() |
long |
getAMResourceLimitVCores() |
long |
getUsedAMResourceMB() |
long |
getUsedAMResourceVCores() |
QueueMetrics |
getUserMetrics(String userName) |
void |
incAMUsed(String partition,
String user,
org.apache.hadoop.yarn.api.records.Resource res) |
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) |
activateApp, addAppAttemptFirstContainerAllocationDelay, allocateResources, allocateResources, clearQueueMetrics, deactivateApp, decrActiveUsers, decrPendingResources, finishApp, finishAppAttempt, forQueue, getActiveApps, getActiveUsers, getAggegatedReleasedContainers, getAggregateAllocatedContainers, getAggregateNodeLocalContainersAllocated, getAggregateOffSwitchContainersAllocated, getAggregateRackLocalContainersAllocated, getAllocatedContainers, getAllocatedMB, getAllocatedResources, getAllocatedVirtualCores, getAppsCompleted, getAppsFailed, getAppsKilled, getAppsPending, getAppsRunning, getAppsSubmitted, getAvailableMB, getAvailableVirtualCores, getMetrics, getMetricsSystem, getPendingContainers, getPendingMB, getPendingVirtualCores, getReservedContainers, getReservedMB, getReservedVirtualCores, incrActiveUsers, incrNodeTypeAggregations, incrPendingResources, moveAppFrom, moveAppTo, releaseResources, releaseResources, reserveResource, reserveResource, runAppAttempt, setAvailableResourcesToQueue, setAvailableResourcesToQueue, setAvailableResourcesToUser, sourceName, submitApp, submitAppAttempt, tag, unreserveResource, unreserveResource
public long getAMResourceLimitMB()
public long getAMResourceLimitVCores()
public long getUsedAMResourceMB()
public long getUsedAMResourceVCores()
public void setAMResouceLimit(String partition, org.apache.hadoop.yarn.api.records.Resource res)
public void setAMResouceLimitForUser(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
public void incAMUsed(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
public void decAMUsed(String partition, String user, org.apache.hadoop.yarn.api.records.Resource res)
public static CSQueueMetrics forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf)
public QueueMetrics getUserMetrics(String userName)
getUserMetrics
in class QueueMetrics
Copyright © 2017 Apache Software Foundation. All Rights Reserved.