org.apache.hadoop.hbase.regionserver

Interface MetricsTableSource

All Superinterfaces:

AutoCloseable, Closeable, Comparable<MetricsTableSource>

All Known Implementing Classes:

MetricsTableSourceImpl

@InterfaceAudience.Private
public interface MetricsTableSource
extends Comparable<MetricsTableSource>, Closeable

This interface will be implemented to allow region server to push table metrics into MetricsRegionAggregateSource that will in turn push data to the Hadoop metrics system.

Field Summary

Fields

Modifier and Type	Field and Description
static String	TABLE_SIZE
static String	TABLE_SIZE_DESC

Method Summary

Modifier and Type	Method and Description
void	close() Close the table's metrics as all the region are closing.
MetricsTableAggregateSource	getAggregateSource() Get the aggregate source to which this reports.
String	getTableName()
void	incrSplitRequest() Increment number of a requested splits
void	incrSplitSuccess() Increment number of successful splits
void	registerMetrics()
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 interface java.lang.Comparable

compareTo

Field Detail

TABLE_SIZE

static final String TABLE_SIZE

See Also:

Constant Field Values

TABLE_SIZE_DESC

static final String TABLE_SIZE_DESC

See Also:

Constant Field Values

Method Detail

getTableName

String getTableName()

close

void close()

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

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

registerMetrics

void registerMetrics()

getAggregateSource

MetricsTableAggregateSource getAggregateSource()

Get the aggregate source to which this reports.

updateSplitTime

void updateSplitTime(long t)

Update the split transaction time histogram

Parameters:

t - time it took, in milliseconds

incrSplitRequest

void incrSplitRequest()

Increment number of a requested splits

incrSplitSuccess

void incrSplitSuccess()

Increment number of successful splits

updateFlushTime

void updateFlushTime(long t)

Update the flush time histogram

Parameters:

t - time it took, in milliseconds

updateFlushMemstoreSize

void updateFlushMemstoreSize(long bytes)

Update the flush memstore size histogram

Parameters:

bytes - the number of bytes in the memstore

updateFlushOutputSize

void updateFlushOutputSize(long bytes)

Update the flush output file size histogram

Parameters:

bytes - the number of bytes in the output file

updateCompactionTime

void updateCompactionTime(boolean isMajor,
                          long t)

Update the compaction time histogram, both major and minor

Parameters:

isMajor - whether compaction is a major compaction

t - time it took, in milliseconds

updateCompactionInputFileCount

void updateCompactionInputFileCount(boolean isMajor,
                                    long c)

Update the compaction input number of files histogram

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionInputSize

void updateCompactionInputSize(boolean isMajor,
                               long bytes)

Update the compaction total input file size histogram

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file

updateCompactionOutputFileCount

void updateCompactionOutputFileCount(boolean isMajor,
                                     long c)

Update the compaction output number of files histogram

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionOutputSize

void updateCompactionOutputSize(boolean isMajor,
                                long bytes)

Update the compaction total output file size

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file