Package org.apache.hadoop.hbase.regionserver

Class MetricsTableSourceImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsTableSourceImpl

All Implemented Interfaces:

Closeable, AutoCloseable, Comparable<MetricsTableSource>, MetricsTableSource

@Private
public class MetricsTableSourceImpl
extends Object
implements MetricsTableSource

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	_COLUMNFAMILY
private final MetricsTableAggregateSourceImpl	agg
private AtomicBoolean	closed
private MutableFastCounter	compactedInputBytes
private MutableFastCounter	compactedOutputBytes
private MetricHistogram	compactionInputFileCountHisto
private MetricHistogram	compactionInputSizeHisto
private MetricHistogram	compactionOutputFileCountHisto
private MetricHistogram	compactionOutputSizeHisto
private MetricHistogram	compactionTimeHisto
private MutableFastCounter	flushedMemstoreBytes
private MutableFastCounter	flushedOutputBytes
private MetricHistogram	flushMemstoreSizeHisto
private MetricHistogram	flushOutputSizeHisto
private MetricHistogram	flushTimeHisto
private final int	hashCode
private static final org.slf4j.Logger	LOG
private MutableFastCounter	majorCompactedInputBytes
private MutableFastCounter	majorCompactedOutputBytes
private MetricHistogram	majorCompactionInputFileCountHisto
private MetricHistogram	majorCompactionInputSizeHisto
private MetricHistogram	majorCompactionOutputFileCountHisto
private MetricHistogram	majorCompactionOutputSizeHisto
private MetricHistogram	majorCompactionTimeHisto
private final DynamicMetricsRegistry	registry
private MutableFastCounter	splitRequest
private MutableFastCounter	splitSuccess
private MetricHistogram	splitTimeHisto
private final TableName	tableName
private final String	tableNamePrefix
private final String	tableNamePrefixPart1
private final String	tableNamePrefixPart2
private MetricsTableWrapperAggregate	tableWrapperAgg

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

TABLE_SIZE, TABLE_SIZE_DESC

Constructor Summary

Constructors

Constructor	Description
MetricsTableSourceImpl(String tblName, MetricsTableAggregateSourceImpl aggregate, MetricsTableWrapperAggregate tblWrapperAgg)

Method Summary

Modifier and Type	Method	Description
private void	addGauge(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, Map<String,Long> metricMap, String metricName, String metricDesc)
void	close()	Close the table's metrics as all the region are closing.
int	compareTo(MetricsTableSource source)
private void	deregisterMetrics()
boolean	equals(Object o)
MetricsTableAggregateSource	getAggregateSource()	Get the aggregate source to which this reports.
String	getTableName()
String	getTableNamePrefix()
MetricsTableWrapperAggregate	getTableWrapper()
int	hashCode()
void	incrSplitRequest()	Increment number of a requested splits
void	incrSplitSuccess()	Increment number of successful splits
void	registerMetrics()
(package private) void	snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, boolean ignored)
void	updateCompactionInputFileCount(boolean isMajor, long c)	Update the compaction input number of files histogram
void	updateCompactionInputSize(boolean isMajor, long bytes)	Update the compaction total input file size histogram
void	updateCompactionOutputFileCount(boolean isMajor, long c)	Update the compaction output number of files histogram
void	updateCompactionOutputSize(boolean isMajor, long bytes)	Update the compaction total output file size
void	updateCompactionTime(boolean isMajor, long t)	Update the compaction time histogram, both major and minor
void	updateFlushMemstoreSize(long bytes)	Update the flush memstore size histogram
void	updateFlushOutputSize(long bytes)	Update the flush output file size histogram
void	updateFlushTime(long t)	Update the flush time histogram
void	updateSplitTime(long t)	Update the split transaction time histogram

Methods inherited from class java.lang.Object

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

Field Details

_COLUMNFAMILY

private static final String _COLUMNFAMILY

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

closed

private AtomicBoolean closed

tableWrapperAgg

private MetricsTableWrapperAggregate tableWrapperAgg

agg

private final MetricsTableAggregateSourceImpl agg

registry

private final DynamicMetricsRegistry registry

tableNamePrefix

private final String tableNamePrefix

tableNamePrefixPart1

private final String tableNamePrefixPart1

tableNamePrefixPart2

private final String tableNamePrefixPart2

tableName

private final TableName tableName

hashCode

private final int hashCode

splitRequest

private MutableFastCounter splitRequest

splitSuccess

private MutableFastCounter splitSuccess

splitTimeHisto

private MetricHistogram splitTimeHisto

flushTimeHisto

private MetricHistogram flushTimeHisto

flushMemstoreSizeHisto

private MetricHistogram flushMemstoreSizeHisto

flushOutputSizeHisto

private MetricHistogram flushOutputSizeHisto

flushedMemstoreBytes

private MutableFastCounter flushedMemstoreBytes

flushedOutputBytes

private MutableFastCounter flushedOutputBytes

compactionTimeHisto

private MetricHistogram compactionTimeHisto

compactionInputFileCountHisto

private MetricHistogram compactionInputFileCountHisto

compactionInputSizeHisto

private MetricHistogram compactionInputSizeHisto

compactionOutputFileCountHisto

private MetricHistogram compactionOutputFileCountHisto

compactionOutputSizeHisto

private MetricHistogram compactionOutputSizeHisto

compactedInputBytes

private MutableFastCounter compactedInputBytes

compactedOutputBytes

private MutableFastCounter compactedOutputBytes

majorCompactionTimeHisto

private MetricHistogram majorCompactionTimeHisto

majorCompactionInputFileCountHisto

private MetricHistogram majorCompactionInputFileCountHisto

majorCompactionInputSizeHisto

private MetricHistogram majorCompactionInputSizeHisto

majorCompactionOutputFileCountHisto

private MetricHistogram majorCompactionOutputFileCountHisto

majorCompactionOutputSizeHisto

private MetricHistogram majorCompactionOutputSizeHisto

majorCompactedInputBytes

private MutableFastCounter majorCompactedInputBytes

majorCompactedOutputBytes

private MutableFastCounter majorCompactedOutputBytes

Constructor Details

MetricsTableSourceImpl

public MetricsTableSourceImpl(String tblName,
 MetricsTableAggregateSourceImpl aggregate,
 MetricsTableWrapperAggregate tblWrapperAgg)

Method Details

registerMetrics

public void registerMetrics()

Specified by:

registerMetrics in interface MetricsTableSource

deregisterMetrics

private void deregisterMetrics()

close

public void close()

Description copied from interface: MetricsTableSource

Close the table's metrics as all the region are closing.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface MetricsTableSource

getAggregateSource

public MetricsTableAggregateSource getAggregateSource()

Description copied from interface: MetricsTableSource

Get the aggregate source to which this reports.

Specified by:

getAggregateSource in interface MetricsTableSource

compareTo

public int compareTo(MetricsTableSource source)

Specified by:

compareTo in interface Comparable<MetricsTableSource>

snapshot

void snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb,
 boolean ignored)

addGauge

private void addGauge(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb,
 Map<String,Long> metricMap,
 String metricName,
 String metricDesc)

getTableName

public String getTableName()

Specified by:

getTableName in interface MetricsTableSource

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

getTableWrapper

public MetricsTableWrapperAggregate getTableWrapper()

getTableNamePrefix

public String getTableNamePrefix()

incrSplitRequest

public void incrSplitRequest()

Description copied from interface: MetricsTableSource

Increment number of a requested splits

Specified by:

incrSplitRequest in interface MetricsTableSource

incrSplitSuccess

public void incrSplitSuccess()

Description copied from interface: MetricsTableSource

Increment number of successful splits

Specified by:

incrSplitSuccess in interface MetricsTableSource

updateSplitTime

public void updateSplitTime(long t)

Description copied from interface: MetricsTableSource

Update the split transaction time histogram

Specified by:

updateSplitTime in interface MetricsTableSource

Parameters:

t - time it took, in milliseconds

updateFlushTime

public void updateFlushTime(long t)

Description copied from interface: MetricsTableSource

Update the flush time histogram

Specified by:

updateFlushTime in interface MetricsTableSource

Parameters:

t - time it took, in milliseconds

updateFlushMemstoreSize

public void updateFlushMemstoreSize(long bytes)

Description copied from interface: MetricsTableSource

Update the flush memstore size histogram

Specified by:

updateFlushMemstoreSize in interface MetricsTableSource

Parameters:

bytes - the number of bytes in the memstore

updateFlushOutputSize

public void updateFlushOutputSize(long bytes)

Description copied from interface: MetricsTableSource

Update the flush output file size histogram

Specified by:

updateFlushOutputSize in interface MetricsTableSource

Parameters:

bytes - the number of bytes in the output file

updateCompactionTime

public void updateCompactionTime(boolean isMajor,
 long t)

Description copied from interface: MetricsTableSource

Update the compaction time histogram, both major and minor

Specified by:

updateCompactionTime in interface MetricsTableSource

Parameters:

isMajor - whether compaction is a major compaction

t - time it took, in milliseconds

updateCompactionInputFileCount

public void updateCompactionInputFileCount(boolean isMajor,
 long c)

Description copied from interface: MetricsTableSource

Update the compaction input number of files histogram

Specified by:

updateCompactionInputFileCount in interface MetricsTableSource

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionInputSize

public void updateCompactionInputSize(boolean isMajor,
 long bytes)

Description copied from interface: MetricsTableSource

Update the compaction total input file size histogram

Specified by:

updateCompactionInputSize in interface MetricsTableSource

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file

updateCompactionOutputFileCount

public void updateCompactionOutputFileCount(boolean isMajor,
 long c)

Description copied from interface: MetricsTableSource

Update the compaction output number of files histogram

Specified by:

updateCompactionOutputFileCount in interface MetricsTableSource

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionOutputSize

public void updateCompactionOutputSize(boolean isMajor,
 long bytes)

Description copied from interface: MetricsTableSource

Update the compaction total output file size

Specified by:

updateCompactionOutputSize in interface MetricsTableSource

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file