org.apache.hadoop.hive.ql.exec.tez

Class WmPoolMetrics

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.WmPoolMetrics

All Implemented Interfaces:

org.apache.hadoop.metrics2.MetricsSource

public class WmPoolMetrics
extends Object
implements org.apache.hadoop.metrics2.MetricsSource

A wrapper for metrics for single WM pool. This outputs metrics both to Codahale and standard Hadoop metrics, in parallel. The codahale output is prefixed with pool name and is mostly for the JMX view, or to look at when Hadoop metrics are not set up. Hadoop metrics are output because they can be tagged properly rather than prefixed, so they are better for dashboards.

Constructor Summary

Constructors

Constructor and Description
WmPoolMetrics(String poolName, org.apache.hadoop.metrics2.MetricsSystem ms)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

WmPoolMetrics

public WmPoolMetrics(String poolName,
                     org.apache.hadoop.metrics2.MetricsSystem ms)

Method Detail

initAfterRegister

public void initAfterRegister()

setParallelQueries

public void setParallelQueries(int size)

setExecutors

public void setExecutors(int allocation)

setMaxExecutors

public void setMaxExecutors(int allocation)

addQueuedQuery

public void addQueuedQuery()

addRunningQuery

public void addRunningQuery()

removeQueuedQueries

public void removeQueuedQueries(int num)

removeRunningQueries

public void removeRunningQueries(int num)

moveQueuedToRunning

public void moveQueuedToRunning()

getMetrics

public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector,
                       boolean all)

Specified by:

getMetrics in interface org.apache.hadoop.metrics2.MetricsSource

create

public static WmPoolMetrics create(String poolName,
                                   org.apache.hadoop.metrics2.MetricsSystem ms)

destroy

public void destroy()