org.apache.hadoop.hbase.master

Class MetricsMasterQuotaSourceImpl

java.lang.Object

org.apache.hadoop.hbase.metrics.BaseSourceImpl

org.apache.hadoop.hbase.master.MetricsMasterQuotaSourceImpl

All Implemented Interfaces:

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

@InterfaceAudience.Private
public class MetricsMasterQuotaSourceImpl
extends BaseSourceImpl
implements MetricsMasterQuotaSource

Implementation of MetricsMasterQuotaSource which writes the values passed in via the interface to the metrics backend.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	namespacesViolatingQuotasGauge
private MetricHistogram	quotaObserverTimeHisto
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	regionSpaceReportsGauge
private MetricHistogram	snapshotObserverSizeComputationTimeHisto
private MetricHistogram	snapshotObserverSnapshotFetchTimeHisto
private MetricHistogram	snapshotObserverTimeHisto
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	spaceQuotasGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	tablesViolatingQuotasGauge
private MetricsMasterWrapper	wrapper

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.master.MetricsMasterQuotaSource

METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, NS_QUOTA_USAGE_DESC, NS_QUOTA_USAGE_NAME, NUM_NS_QUOTA_VIOLATIONS_DESC, NUM_NS_QUOTA_VIOLATIONS_NAME, NUM_REGION_SIZE_REPORTS_DESC, NUM_REGION_SIZE_REPORTS_NAME, NUM_SPACE_QUOTAS_DESC, NUM_SPACE_QUOTAS_NAME, NUM_TABLES_QUOTA_VIOLATIONS_DESC, NUM_TABLES_QUOTA_VIOLATIONS_NAME, QUOTA_OBSERVER_CHORE_TIME_DESC, QUOTA_OBSERVER_CHORE_TIME_NAME, SNAPSHOT_OBSERVER_CHORE_TIME_DESC, SNAPSHOT_OBSERVER_CHORE_TIME_NAME, SNAPSHOT_OBSERVER_FETCH_TIME_DESC, SNAPSHOT_OBSERVER_FETCH_TIME_NAME, SNAPSHOT_OBSERVER_SIZE_COMPUTATION_TIME_DESC, SNAPSHOT_OBSERVER_SIZE_COMPUTATION_TIME_NAME, TABLE_QUOTA_USAGE_DESC, TABLE_QUOTA_USAGE_NAME

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

HBASE_METRICS_SYSTEM_NAME

Constructor Summary

Constructors

Constructor and Description
MetricsMasterQuotaSourceImpl(MetricsMasterWrapper wrapper)
MetricsMasterQuotaSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext, MetricsMasterWrapper wrapper)

Method Summary

Modifier and Type	Method and Description
private String	generateJsonQuotaSummary(Iterable<Map.Entry<String,Map.Entry<Long,Long>>> data, String target) Summarizes the usage and limit for many targets (table or namespace) into JSON.
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)
void	incrementSnapshotObserverChoreTime(long time) Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore which runs periodically.
void	incrementSnapshotObserverSnapshotComputationTime(long time) Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore to compute the size of one snapshot, relative to the files referenced by the originating table.
void	incrementSnapshotObserverSnapshotFetchTime(long time) Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore to fetch all snapshots.
void	incrementSpaceQuotaObserverChoreTime(long time) Updates the metric tracking the amount of time taken by the QuotaObserverChore which runs periodically.
void	updateNumCurrentSpaceQuotaRegionSizeReports(long numCurrentRegionSizeReports) Updates the metric tracking the number of region size reports the master is currently retaining in memory.
void	updateNumNamespacesInSpaceQuotaViolation(long numNamespacesInViolation) Updates the metric tracking the number of namespaces the master has computed to be in violation of their space quota.
void	updateNumSpaceQuotas(long numSpaceQuotas) Updates the metric tracking the number of space quotas defined in the system.
void	updateNumTablesInSpaceQuotaViolation(long numTablesInViolation) Updates the metric tracking the number of tables the master has computed to be in violation of their space quota.

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

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

Field Detail

wrapper

private final MetricsMasterWrapper wrapper

spaceQuotasGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong spaceQuotasGauge

tablesViolatingQuotasGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong tablesViolatingQuotasGauge

namespacesViolatingQuotasGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong namespacesViolatingQuotasGauge

regionSpaceReportsGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong regionSpaceReportsGauge

quotaObserverTimeHisto

private final MetricHistogram quotaObserverTimeHisto

snapshotObserverTimeHisto

private final MetricHistogram snapshotObserverTimeHisto

snapshotObserverSizeComputationTimeHisto

private final MetricHistogram snapshotObserverSizeComputationTimeHisto

snapshotObserverSnapshotFetchTimeHisto

private final MetricHistogram snapshotObserverSnapshotFetchTimeHisto

Constructor Detail

MetricsMasterQuotaSourceImpl

public MetricsMasterQuotaSourceImpl(MetricsMasterWrapper wrapper)

MetricsMasterQuotaSourceImpl

public MetricsMasterQuotaSourceImpl(String metricsName,
                                    String metricsDescription,
                                    String metricsContext,
                                    String metricsJmxContext,
                                    MetricsMasterWrapper wrapper)

Method Detail

updateNumSpaceQuotas

public void updateNumSpaceQuotas(long numSpaceQuotas)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the number of space quotas defined in the system.

Specified by:

updateNumSpaceQuotas in interface MetricsMasterQuotaSource

Parameters:

numSpaceQuotas - The number of space quotas defined

updateNumTablesInSpaceQuotaViolation

public void updateNumTablesInSpaceQuotaViolation(long numTablesInViolation)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the number of tables the master has computed to be in violation of their space quota.

Specified by:

updateNumTablesInSpaceQuotaViolation in interface MetricsMasterQuotaSource

Parameters:

numTablesInViolation - The number of tables violating a space quota

updateNumNamespacesInSpaceQuotaViolation

public void updateNumNamespacesInSpaceQuotaViolation(long numNamespacesInViolation)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the number of namespaces the master has computed to be in violation of their space quota.

Specified by:

updateNumNamespacesInSpaceQuotaViolation in interface MetricsMasterQuotaSource

Parameters:

numNamespacesInViolation - The number of namespaces violating a space quota

updateNumCurrentSpaceQuotaRegionSizeReports

public void updateNumCurrentSpaceQuotaRegionSizeReports(long numCurrentRegionSizeReports)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the number of region size reports the master is currently retaining in memory.

Specified by:

updateNumCurrentSpaceQuotaRegionSizeReports in interface MetricsMasterQuotaSource

Parameters:

numCurrentRegionSizeReports - The number of region size reports the master is holding in memory

incrementSpaceQuotaObserverChoreTime

public void incrementSpaceQuotaObserverChoreTime(long time)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the amount of time taken by the QuotaObserverChore which runs periodically.

Specified by:

incrementSpaceQuotaObserverChoreTime in interface MetricsMasterQuotaSource

Parameters:

time - The execution time of the chore in milliseconds

incrementSnapshotObserverChoreTime

public void incrementSnapshotObserverChoreTime(long time)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore which runs periodically.

Specified by:

incrementSnapshotObserverChoreTime in interface MetricsMasterQuotaSource

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

generateJsonQuotaSummary

private String generateJsonQuotaSummary(Iterable<Map.Entry<String,Map.Entry<Long,Long>>> data,
                                        String target)

Summarizes the usage and limit for many targets (table or namespace) into JSON.

incrementSnapshotObserverSnapshotComputationTime

public void incrementSnapshotObserverSnapshotComputationTime(long time)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore to compute the size of one snapshot, relative to the files referenced by the originating table.

Specified by:

incrementSnapshotObserverSnapshotComputationTime in interface MetricsMasterQuotaSource

incrementSnapshotObserverSnapshotFetchTime

public void incrementSnapshotObserverSnapshotFetchTime(long time)

Description copied from interface: MetricsMasterQuotaSource

Updates the metric tracking the amount of time taken by the SnapshotQuotaObserverChore to fetch all snapshots.

Specified by:

incrementSnapshotObserverSnapshotFetchTime in interface MetricsMasterQuotaSource