org.apache.hadoop.hbase.regionserver

Class MetricsTableSourceImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsTableSourceImpl

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Comparable<MetricsTableSource>, MetricsTableSource

@InterfaceAudience.Private
public class MetricsTableSourceImpl
extends java.lang.Object
implements MetricsTableSource

Field Summary

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

TABLE_SIZE, TABLE_SIZE_DESC

Constructor Summary

Constructors

Constructor and Description
MetricsTableSourceImpl(java.lang.String tblName, MetricsTableAggregateSourceImpl aggregate, MetricsTableWrapperAggregate tblWrapperAgg)

Method Summary

Modifier and Type	Method and Description
void	close() Close the table's metrics as all the region are closing.
int	compareTo(MetricsTableSource source)
boolean	equals(java.lang.Object o)
MetricsTableAggregateSource	getAggregateSource() Get the aggregate source to which this reports.
java.lang.String	getTableName()
java.lang.String	getTableNamePrefix()
MetricsTableWrapperAggregate	getTableWrapper()
int	hashCode()
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 class java.lang.Object

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

Constructor Detail

MetricsTableSourceImpl

public MetricsTableSourceImpl(java.lang.String tblName,
                              MetricsTableAggregateSourceImpl aggregate,
                              MetricsTableWrapperAggregate tblWrapperAgg)

Method Detail

registerMetrics

public void registerMetrics()

Specified by:

registerMetrics in interface MetricsTableSource

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 java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

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 java.lang.Comparable<MetricsTableSource>

getTableName

public java.lang.String getTableName()

Specified by:

getTableName in interface MetricsTableSource

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

getTableWrapper

public MetricsTableWrapperAggregate getTableWrapper()

getTableNamePrefix

public java.lang.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