|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics
@InterfaceAudience.Private @Metrics(context="yarn") public class QueueMetrics
Field Summary | |
---|---|
protected static org.apache.hadoop.metrics2.MetricsInfo |
QUEUE_INFO
|
protected static Map<String,QueueMetrics> |
queueMetrics
Simple metrics cache to help prevent re-registrations. |
Constructor Summary | |
---|---|
protected |
QueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms,
String queueName,
Queue parent,
boolean enableUserMetrics,
org.apache.hadoop.conf.Configuration conf)
|
Method Summary | |
---|---|
void |
activateApp(String user)
|
void |
allocateResources(String user,
int containers,
org.apache.hadoop.yarn.api.records.Resource res)
|
static void |
clearQueueMetrics()
Helper method to clear cache - used only for unit tests. |
void |
deactivateApp(String user)
|
void |
decrActiveUsers()
|
void |
decrPendingResources(String user,
int containers,
org.apache.hadoop.yarn.api.records.Resource res)
|
void |
finishApp(AppSchedulingInfo app,
RMAppAttemptState rmAppAttemptFinalState)
|
static QueueMetrics |
forQueue(org.apache.hadoop.metrics2.MetricsSystem ms,
String queueName,
Queue parent,
boolean enableUserMetrics,
org.apache.hadoop.conf.Configuration conf)
|
static QueueMetrics |
forQueue(String queueName,
Queue parent,
boolean enableUserMetrics,
org.apache.hadoop.conf.Configuration conf)
|
int |
getActiveApps()
|
int |
getActiveUsers()
|
int |
getAllocatedContainers()
|
int |
getAllocatedMB()
|
org.apache.hadoop.yarn.api.records.Resource |
getAllocatedResources()
|
int |
getAllocatedVirtualCores()
|
int |
getAppsCompleted()
|
int |
getAppsFailed()
|
int |
getAppsKilled()
|
int |
getAppsPending()
|
int |
getAppsRunning()
|
int |
getAppsSubmitted()
|
int |
getAvailableMB()
|
int |
getAvailableVirtualCores()
|
void |
getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector,
boolean all)
|
int |
getPendingContainers()
|
int |
getPendingMB()
|
int |
getPendingVirtualCores()
|
int |
getReservedContainers()
|
int |
getReservedMB()
|
int |
getReservedVirtualCores()
|
QueueMetrics |
getUserMetrics(String userName)
|
void |
incrActiveUsers()
|
void |
incrAppsRunning(AppSchedulingInfo app,
String user)
|
void |
incrPendingResources(String user,
int containers,
org.apache.hadoop.yarn.api.records.Resource res)
Increment pending resource metrics |
void |
releaseResources(String user,
int containers,
org.apache.hadoop.yarn.api.records.Resource res)
|
void |
reserveResource(String user,
org.apache.hadoop.yarn.api.records.Resource res)
|
void |
setAvailableResourcesToQueue(org.apache.hadoop.yarn.api.records.Resource limit)
Set available resources. |
void |
setAvailableResourcesToUser(String user,
org.apache.hadoop.yarn.api.records.Resource limit)
Set available resources. |
protected static StringBuilder |
sourceName(String queueName)
|
void |
submitApp(String user,
int attemptId)
|
protected QueueMetrics |
tag(org.apache.hadoop.metrics2.MetricsInfo info,
String value)
|
void |
unreserveResource(String user,
org.apache.hadoop.yarn.api.records.Resource res)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final org.apache.hadoop.metrics2.MetricsInfo QUEUE_INFO
protected static final Map<String,QueueMetrics> queueMetrics
Constructor Detail |
---|
protected QueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf)
Method Detail |
---|
protected QueueMetrics tag(org.apache.hadoop.metrics2.MetricsInfo info, String value)
protected static StringBuilder sourceName(String queueName)
public static QueueMetrics forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf)
@InterfaceAudience.Private public static void clearQueueMetrics()
public static QueueMetrics forQueue(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf)
public QueueMetrics getUserMetrics(String userName)
public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector, boolean all)
getMetrics
in interface org.apache.hadoop.metrics2.MetricsSource
public void submitApp(String user, int attemptId)
public void incrAppsRunning(AppSchedulingInfo app, String user)
public void finishApp(AppSchedulingInfo app, RMAppAttemptState rmAppAttemptFinalState)
public void setAvailableResourcesToQueue(org.apache.hadoop.yarn.api.records.Resource limit)
limit
- resource limitpublic void setAvailableResourcesToUser(String user, org.apache.hadoop.yarn.api.records.Resource limit)
user
- limit
- resource limitpublic void incrPendingResources(String user, int containers, org.apache.hadoop.yarn.api.records.Resource res)
user
- containers
- res
- the TOTAL delta of resources note this is different from
the other APIs which use per container resourcepublic void decrPendingResources(String user, int containers, org.apache.hadoop.yarn.api.records.Resource res)
public void allocateResources(String user, int containers, org.apache.hadoop.yarn.api.records.Resource res)
public void releaseResources(String user, int containers, org.apache.hadoop.yarn.api.records.Resource res)
public void reserveResource(String user, org.apache.hadoop.yarn.api.records.Resource res)
public void unreserveResource(String user, org.apache.hadoop.yarn.api.records.Resource res)
public void incrActiveUsers()
public void decrActiveUsers()
public void activateApp(String user)
public void deactivateApp(String user)
public int getAppsSubmitted()
public int getAppsRunning()
public int getAppsPending()
public int getAppsCompleted()
public int getAppsKilled()
public int getAppsFailed()
public org.apache.hadoop.yarn.api.records.Resource getAllocatedResources()
public int getAllocatedMB()
public int getAllocatedVirtualCores()
public int getAllocatedContainers()
public int getAvailableMB()
public int getAvailableVirtualCores()
public int getPendingMB()
public int getPendingVirtualCores()
public int getPendingContainers()
public int getReservedMB()
public int getReservedVirtualCores()
public int getReservedContainers()
public int getActiveUsers()
public int getActiveApps()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |