org.apache.hadoop.hbase.regionserver

Class MetricsTableLatenciesImpl

java.lang.Object

org.apache.hadoop.hbase.metrics.BaseSourceImpl

org.apache.hadoop.hbase.regionserver.MetricsTableLatenciesImpl

All Implemented Interfaces:

BaseSource, MetricsTableLatencies, org.apache.hadoop.metrics2.MetricsSource

@InterfaceAudience.Private
public class MetricsTableLatenciesImpl
extends BaseSourceImpl
implements MetricsTableLatencies

Implementation of MetricsTableLatencies to track latencies for one table in a RegionServer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetricsTableLatenciesImpl.TableHistograms

Field Summary

Fields

Modifier and Type	Field and Description
private HashMap<TableName,MetricsTableLatenciesImpl.TableHistograms>	histogramsByTable

Fields inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry

Fields inherited from interface org.apache.hadoop.hbase.regionserver.MetricsTableLatencies

APPEND_TIME, CHECK_AND_DELETE_TIME, CHECK_AND_MUTATE_TIME, CHECK_AND_PUT_TIME, DELETE_BATCH_TIME, DELETE_TIME, GET_TIME, INCREMENT_TIME, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, PUT_BATCH_TIME, PUT_TIME, SCAN_SIZE, SCAN_TIME

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

HBASE_METRICS_SYSTEM_NAME

Constructor Summary

Constructors

Constructor and Description
MetricsTableLatenciesImpl()
MetricsTableLatenciesImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)

Method Summary

Modifier and Type	Method and Description
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)
MetricsTableLatenciesImpl.TableHistograms	getOrCreateTableHistogram(String tableName)
static String	qualifyMetricsName(TableName tableName, String metric)
void	updateAppend(String tableName, long t) Update the Append time histogram.
void	updateCheckAndDelete(String tableName, long time) Update the CheckAndDelete time histogram.
void	updateCheckAndMutate(String tableName, long time) Update the CheckAndMutate time histogram.
void	updateCheckAndPut(String tableName, long time) Update the CheckAndPut time histogram.
void	updateDelete(String tableName, long t) Update the Delete time histogram
void	updateDeleteBatch(String tableName, long t) Update the batch Delete time histogram
void	updateGet(String tableName, long t) Update the Get time histogram .
void	updateIncrement(String tableName, long t) Update the Increment time histogram.
void	updatePut(String tableName, long t) Update the Put time histogram
void	updatePutBatch(String tableName, long t) Update the batch Put time histogram
void	updateScanSize(String tableName, long scanSize) Update the scan size.
void	updateScanTime(String tableName, long t) Update the scan time.

Methods inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram

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 Detail

histogramsByTable

private final HashMap<TableName,MetricsTableLatenciesImpl.TableHistograms> histogramsByTable

Constructor Detail

MetricsTableLatenciesImpl

public MetricsTableLatenciesImpl()

MetricsTableLatenciesImpl

public MetricsTableLatenciesImpl(String metricsName,
                                 String metricsDescription,
                                 String metricsContext,
                                 String metricsJmxContext)

Method Detail

qualifyMetricsName

public static String qualifyMetricsName(TableName tableName,
                                        String metric)

getOrCreateTableHistogram

public MetricsTableLatenciesImpl.TableHistograms getOrCreateTableHistogram(String tableName)

updatePut

public void updatePut(String tableName,
                      long t)

Description copied from interface: MetricsTableLatencies

Update the Put time histogram

Specified by:

updatePut in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updatePutBatch

public void updatePutBatch(String tableName,
                           long t)

Description copied from interface: MetricsTableLatencies

Update the batch Put time histogram

Specified by:

updatePutBatch in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateDelete

public void updateDelete(String tableName,
                         long t)

Description copied from interface: MetricsTableLatencies

Update the Delete time histogram

Specified by:

updateDelete in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateDeleteBatch

public void updateDeleteBatch(String tableName,
                              long t)

Description copied from interface: MetricsTableLatencies

Update the batch Delete time histogram

Specified by:

updateDeleteBatch in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateGet

public void updateGet(String tableName,
                      long t)

Description copied from interface: MetricsTableLatencies

Update the Get time histogram .

Specified by:

updateGet in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateIncrement

public void updateIncrement(String tableName,
                            long t)

Description copied from interface: MetricsTableLatencies

Update the Increment time histogram.

Specified by:

updateIncrement in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateAppend

public void updateAppend(String tableName,
                         long t)

Description copied from interface: MetricsTableLatencies

Update the Append time histogram.

Specified by:

updateAppend in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateScanSize

public void updateScanSize(String tableName,
                           long scanSize)

Description copied from interface: MetricsTableLatencies

Update the scan size.

Specified by:

updateScanSize in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

scanSize - size of the scan

updateScanTime

public void updateScanTime(String tableName,
                           long t)

Description copied from interface: MetricsTableLatencies

Update the scan time.

Specified by:

updateScanTime in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

t - time it took

updateCheckAndDelete

public void updateCheckAndDelete(String tableName,
                                 long time)

Description copied from interface: MetricsTableLatencies

Update the CheckAndDelete time histogram.

Specified by:

updateCheckAndDelete in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

time - time it took

updateCheckAndPut

public void updateCheckAndPut(String tableName,
                              long time)

Description copied from interface: MetricsTableLatencies

Update the CheckAndPut time histogram.

Specified by:

updateCheckAndPut in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

time - time it took

updateCheckAndMutate

public void updateCheckAndMutate(String tableName,
                                 long time)

Description copied from interface: MetricsTableLatencies

Update the CheckAndMutate time histogram.

Specified by:

updateCheckAndMutate in interface MetricsTableLatencies

Parameters:

tableName - The table the metric is for

time - time it took

getMetrics

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

Specified by:

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

Overrides:

getMetrics in class BaseSourceImpl