public class WmPoolMetrics extends Object implements org.apache.hadoop.metrics2.MetricsSource
Constructor and Description |
---|
WmPoolMetrics(String poolName,
org.apache.hadoop.metrics2.MetricsSystem ms) |
Modifier and Type | Method and Description |
---|---|
void |
addQueuedQuery() |
void |
addRunningQuery() |
static WmPoolMetrics |
create(String poolName,
org.apache.hadoop.metrics2.MetricsSystem ms) |
void |
destroy() |
void |
getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector,
boolean all) |
void |
initAfterRegister() |
void |
moveQueuedToRunning() |
void |
removeQueuedQueries(int num) |
void |
removeRunningQueries(int num) |
void |
setExecutors(int allocation) |
void |
setMaxExecutors(int allocation) |
void |
setParallelQueries(int size) |
public WmPoolMetrics(String poolName, org.apache.hadoop.metrics2.MetricsSystem ms)
public void initAfterRegister()
public void setParallelQueries(int size)
public void setExecutors(int allocation)
public void setMaxExecutors(int allocation)
public void addQueuedQuery()
public void addRunningQuery()
public void removeQueuedQueries(int num)
public void removeRunningQueries(int num)
public void moveQueuedToRunning()
public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector, boolean all)
getMetrics
in interface org.apache.hadoop.metrics2.MetricsSource
public static WmPoolMetrics create(String poolName, org.apache.hadoop.metrics2.MetricsSystem ms)
public void destroy()
Copyright © 2022 The Apache Software Foundation. All rights reserved.