MetricsTableSourceImpl (Apache HBase 2.5.0 API)

java.lang.Object
- org.apache.hadoop.hbase.regionserver.MetricsTableSourceImpl

All Implemented Interfaces:: Closeable, AutoCloseable, Comparable<MetricsTableSource>, MetricsTableSource

@InterfaceAudience.Private
public class MetricsTableSourceImpl
extends Object
implements MetricsTableSource

Field Summary

Fields
Modifier and Type	Field and Description
`private static String`	`_COLUMNFAMILY`
`private 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 int`	`hashCode`
`private static 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 DynamicMetricsRegistry`	`registry`
`private MutableFastCounter`	`splitRequest`
`private MutableFastCounter`	`splitSuccess`
`private MetricHistogram`	`splitTimeHisto`
`private TableName`	`tableName`
`private String`	`tableNamePrefix`
`private String`	`tableNamePrefixPart1`
`private String`	`tableNamePrefixPart2`
`private MetricsTableWrapperAggregate`	`tableWrapperAgg`

Fields inherited from interface org.apache.hadoop.hbase.regionserver.MetricsTableSource
TABLE_SIZE, TABLE_SIZE_DESC

Constructor Summary

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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 Detail
  - _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 Detail
  - MetricsTableSourceImpl
```
public MetricsTableSourceImpl(String tblName,
                              MetricsTableAggregateSourceImpl aggregate,
                              MetricsTableWrapperAggregate tblWrapperAgg)
```
- Method Detail
  - 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 Closeable
    
    Specified by:
    
    close in interface 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 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

Class MetricsTableSourceImpl

Field Summary

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

_COLUMNFAMILY

LOG

closed

tableWrapperAgg

agg

registry

tableNamePrefix

tableNamePrefixPart1

tableNamePrefixPart2

tableName

hashCode

splitRequest

splitSuccess

splitTimeHisto

flushTimeHisto

flushMemstoreSizeHisto

flushOutputSizeHisto

flushedMemstoreBytes

flushedOutputBytes

compactionTimeHisto

compactionInputFileCountHisto

compactionInputSizeHisto

compactionOutputFileCountHisto

compactionOutputSizeHisto

compactedInputBytes

compactedOutputBytes

majorCompactionTimeHisto

majorCompactionInputFileCountHisto

majorCompactionInputSizeHisto

majorCompactionOutputFileCountHisto

majorCompactionOutputSizeHisto

majorCompactedInputBytes

majorCompactedOutputBytes

Constructor Detail

MetricsTableSourceImpl

Method Detail

registerMetrics

deregisterMetrics

close

getAggregateSource

compareTo

snapshot

addGauge

getTableName

hashCode

equals

getTableWrapper

getTableNamePrefix

incrSplitRequest

incrSplitSuccess

updateSplitTime

updateFlushTime

updateFlushMemstoreSize

updateFlushOutputSize

updateCompactionTime

updateCompactionInputFileCount

updateCompactionInputSize

updateCompactionOutputFileCount

updateCompactionOutputSize