Package org.apache.hadoop.hbase.replication.regionserver

Class MetricsReplicationTableSourceImpl

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationTableSourceImpl

All Implemented Interfaces:

BaseSource, MetricsReplicationTableSource

@Private
public class MetricsReplicationTableSourceImpl
extends Object
implements MetricsReplicationTableSource

This is the metric source for table level replication metrics. We can easy monitor some useful table level replication metrics such as ageOfLastShippedOp and shippedBytes

Field Summary

Fields

Modifier and Type	Field	Description
private final MutableHistogram	ageOfLastShippedOpHist
private final String	ageOfLastShippedOpKey
private String	keyPrefix
private final MetricsReplicationSourceImpl	rms
private final MutableFastCounter	shippedBytesCounter
private final String	shippedBytesKey
private final String	tableName

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

HBASE_METRICS_SYSTEM_NAME

Constructor Summary

Constructors

Constructor	Description
MetricsReplicationTableSourceImpl(MetricsReplicationSourceImpl rms, String tableName)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	decGauge(String gaugeName, long delta)	Subtract some amount from a gauge.
long	getLastShippedAge()
String	getMetricsContext()	Get the metrics context.
String	getMetricsDescription()	Get the description of what this source exposes.
String	getMetricsJmxContext()	Get the name of the context in JMX that this source will be exposed through.
String	getMetricsName()	Get the name of the metrics that are being exported by this source.
long	getShippedBytes()
void	incCounters(String counterName, long delta)	Add some amount to a counter.
void	incGauge(String gaugeName, long delta)	Add some amount to a gauge.
void	incrShippedBytes(long size)
void	init()	Clear out the metrics and re-prepare the source.
void	removeMetric(String key)	Remove a metric and no longer announce it.
void	setGauge(String gaugeName, long value)	Set a gauge to a specific value.
void	setLastShippedAge(long age)
void	updateHistogram(String name, long value)	Add some value to a histogram.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

getMetricRegistryInfo

Field Details

rms

private final MetricsReplicationSourceImpl rms

tableName

private final String tableName

ageOfLastShippedOpKey

private final String ageOfLastShippedOpKey

keyPrefix

private String keyPrefix

shippedBytesKey

private final String shippedBytesKey

ageOfLastShippedOpHist

private final MutableHistogram ageOfLastShippedOpHist

shippedBytesCounter

private final MutableFastCounter shippedBytesCounter

Constructor Details

MetricsReplicationTableSourceImpl

public MetricsReplicationTableSourceImpl(MetricsReplicationSourceImpl rms,
 String tableName)

Method Details

setLastShippedAge

public void setLastShippedAge(long age)

Specified by:

setLastShippedAge in interface MetricsReplicationTableSource

incrShippedBytes

public void incrShippedBytes(long size)

Specified by:

incrShippedBytes in interface MetricsReplicationTableSource

clear

public void clear()

Specified by:

clear in interface MetricsReplicationTableSource

getLastShippedAge

public long getLastShippedAge()

Specified by:

getLastShippedAge in interface MetricsReplicationTableSource

getShippedBytes

public long getShippedBytes()

Specified by:

getShippedBytes in interface MetricsReplicationTableSource

init

public void init()

Description copied from interface: BaseSource

Clear out the metrics and re-prepare the source.

Specified by:

init in interface BaseSource

setGauge

public void setGauge(String gaugeName,
 long value)

Description copied from interface: BaseSource

Set a gauge to a specific value.

Specified by:

setGauge in interface BaseSource

Parameters:

gaugeName - the name of the gauge

value - the value

incGauge

public void incGauge(String gaugeName,
 long delta)

Description copied from interface: BaseSource

Add some amount to a gauge.

Specified by:

incGauge in interface BaseSource

Parameters:

gaugeName - the name of the gauge

delta - the amount to change the gauge by.

decGauge

public void decGauge(String gaugeName,
 long delta)

Description copied from interface: BaseSource

Subtract some amount from a gauge.

Specified by:

decGauge in interface BaseSource

Parameters:

gaugeName - the name of the gauge

delta - the amount to change the gauge by.

removeMetric

public void removeMetric(String key)

Description copied from interface: BaseSource

Remove a metric and no longer announce it.

Specified by:

removeMetric in interface BaseSource

Parameters:

key - Name of the gauge to remove.

incCounters

public void incCounters(String counterName,
 long delta)

Description copied from interface: BaseSource

Add some amount to a counter.

Specified by:

incCounters in interface BaseSource

Parameters:

counterName - the name of the counter

delta - the amount to change the counter by.

updateHistogram

public void updateHistogram(String name,
 long value)

Description copied from interface: BaseSource

Add some value to a histogram.

Specified by:

updateHistogram in interface BaseSource

Parameters:

name - the name of the histogram

value - the value to add to the histogram

getMetricsContext

public String getMetricsContext()

Description copied from interface: BaseSource

Get the metrics context. For hadoop metrics2 system this is usually an all lowercased string. eg. regionserver, master, thriftserver

Specified by:

getMetricsContext in interface BaseSource

Returns:

The string context used to register this source to hadoop's metrics2 system.

getMetricsDescription

public String getMetricsDescription()

Description copied from interface: BaseSource

Get the description of what this source exposes.

Specified by:

getMetricsDescription in interface BaseSource

getMetricsJmxContext

public String getMetricsJmxContext()

Description copied from interface: BaseSource

Get the name of the context in JMX that this source will be exposed through. This is in ObjectName format. With the default context being Hadoop -> HBase

Specified by:

getMetricsJmxContext in interface BaseSource

getMetricsName

public String getMetricsName()

Description copied from interface: BaseSource

Get the name of the metrics that are being exported by this source. Eg. IPC, GC, WAL

Specified by:

getMetricsName in interface BaseSource