Package org.apache.hadoop.hbase.regionserver

Class MetricsRegionSourceImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsRegionSourceImpl

All Implemented Interfaces:

Comparable<MetricsRegionSource>, MetricsRegionSource

@Private
public class MetricsRegionSourceImpl
extends Object
implements MetricsRegionSource

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	_STORE
private final MetricsRegionAggregateSourceImpl	agg
private AtomicBoolean	closed
private final int	hashCode
private static final org.slf4j.Logger	LOG
private final MutableFastCounter	regionAppend
private final String	regionAppendKey
private final MutableFastCounter	regionDelete
private final String	regionDeleteKey
private final MutableFastCounter	regionGet
private final String	regionGetKey
private final MutableFastCounter	regionIncrement
private final String	regionIncrementKey
private final String	regionNamePrefix
private final String	regionNamePrefix1
private final String	regionNamePrefix2
private final MutableFastCounter	regionPut
private final String	regionPutKey
private final MutableFastCounter	regionScan
private final String	regionScanKey
private MetricsRegionWrapper	regionWrapper
private final DynamicMetricsRegistry	registry

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

COMPACTIONS_COMPLETED_COUNT, COMPACTIONS_COMPLETED_DESC, COMPACTIONS_FAILED_COUNT, COMPACTIONS_FAILED_DESC, COMPACTIONS_QUEUED_COUNT, COMPACTIONS_QUEUED_DESC, COPROCESSOR_EXECUTION_STATISTICS, COPROCESSOR_EXECUTION_STATISTICS_DESC, FLUSHES_QUEUED_COUNT, FLUSHES_QUEUED_DESC, LAST_MAJOR_COMPACTION_AGE, LAST_MAJOR_COMPACTION_DESC, MAX_COMPACTION_QUEUE_DESC, MAX_COMPACTION_QUEUE_SIZE, MAX_FLUSH_QUEUE_DESC, MAX_FLUSH_QUEUE_SIZE, MIXED_ROW_READS, MIXED_ROW_READS_ON_STORE_DESC, NUM_BYTES_COMPACTED_COUNT, NUM_BYTES_COMPACTED_DESC, NUM_FILES_COMPACTED_COUNT, NUM_FILES_COMPACTED_DESC, OPS_SAMPLE_NAME, REPLICA_ID, REPLICA_ID_DESC, ROW_READS_ONLY_ON_MEMSTORE, ROW_READS_ONLY_ON_MEMSTORE_DESC, SIZE_VALUE_NAME

Constructor Summary

Constructors

Constructor	Description
MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper, MetricsRegionAggregateSourceImpl aggregate)

Method Summary

Modifier and Type	Method	Description
private void	addCounter(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, Map<String,Long> metricMap, String metricName, String metricDesc)
void	close()	Close the region's metrics as this region is closing.
int	compareTo(MetricsRegionSource source)
boolean	equals(Object obj)
MetricsRegionAggregateSource	getAggregateSource()	Get the aggregate source to which this reports.
int	hashCode()
(package private) void	snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, boolean ignored)
void	updateAppend()	Update related counts of appends.
void	updateDelete()	Update related counts of deletes.
void	updateGet(long mills)	Update time of gets
void	updateIncrement()	Update related counts of increments.
void	updatePut()	Update related counts of puts.
void	updateScanTime(long mills)	Update time used of resultScanner.next().

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

_STORE

private static final String _STORE

See Also:

• Constant Field Values

closed

private AtomicBoolean closed

regionWrapper

private MetricsRegionWrapper regionWrapper

agg

private final MetricsRegionAggregateSourceImpl agg

registry

private final DynamicMetricsRegistry registry

regionNamePrefix

private final String regionNamePrefix

regionNamePrefix1

private final String regionNamePrefix1

regionNamePrefix2

private final String regionNamePrefix2

regionPutKey

private final String regionPutKey

regionDeleteKey

private final String regionDeleteKey

regionGetKey

private final String regionGetKey

regionIncrementKey

private final String regionIncrementKey

regionAppendKey

private final String regionAppendKey

regionScanKey

private final String regionScanKey

regionPut

private final MutableFastCounter regionPut

regionDelete

private final MutableFastCounter regionDelete

regionIncrement

private final MutableFastCounter regionIncrement

regionAppend

private final MutableFastCounter regionAppend

regionGet

private final MutableFastCounter regionGet

regionScan

private final MutableFastCounter regionScan

hashCode

private final int hashCode

Constructor Details

MetricsRegionSourceImpl

public MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper,
 MetricsRegionAggregateSourceImpl aggregate)

Method Details

close

public void close()

Description copied from interface: MetricsRegionSource

Close the region's metrics as this region is closing.

Specified by:

close in interface MetricsRegionSource

updatePut

public void updatePut()

Description copied from interface: MetricsRegionSource

Update related counts of puts.

Specified by:

updatePut in interface MetricsRegionSource

updateDelete

public void updateDelete()

Description copied from interface: MetricsRegionSource

Update related counts of deletes.

Specified by:

updateDelete in interface MetricsRegionSource

updateGet

public void updateGet(long mills)

Description copied from interface: MetricsRegionSource

Update time of gets

Specified by:

updateGet in interface MetricsRegionSource

Parameters:

mills - time for this get operation.

updateScanTime

public void updateScanTime(long mills)

Description copied from interface: MetricsRegionSource

Update time used of resultScanner.next().

Specified by:

updateScanTime in interface MetricsRegionSource

updateIncrement

public void updateIncrement()

Description copied from interface: MetricsRegionSource

Update related counts of increments.

Specified by:

updateIncrement in interface MetricsRegionSource

updateAppend

public void updateAppend()

Description copied from interface: MetricsRegionSource

Update related counts of appends.

Specified by:

updateAppend in interface MetricsRegionSource

getAggregateSource

public MetricsRegionAggregateSource getAggregateSource()

Description copied from interface: MetricsRegionSource

Get the aggregate source to which this reports.

Specified by:

getAggregateSource in interface MetricsRegionSource

compareTo

public int compareTo(MetricsRegionSource source)

Specified by:

compareTo in interface Comparable<MetricsRegionSource>

snapshot

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

addCounter

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object