org.apache.hadoop.hbase.regionserver

Class MetricsRegionSourceImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsRegionSourceImpl

All Implemented Interfaces:

Comparable<MetricsRegionSource>, MetricsRegionSource

@InterfaceAudience.Private
public class MetricsRegionSourceImpl
extends Object
implements MetricsRegionSource

Field Summary

Fields

Modifier and Type	Field and Description
private static String	_STORE
private MetricsRegionAggregateSourceImpl	agg
private AtomicBoolean	closed
private int	hashCode
private static org.slf4j.Logger	LOG
private MutableFastCounter	regionAppend
private String	regionAppendKey
private MutableFastCounter	regionDelete
private String	regionDeleteKey
private MutableFastCounter	regionGet
private String	regionGetKey
private MutableFastCounter	regionIncrement
private String	regionIncrementKey
private String	regionNamePrefix
private String	regionNamePrefix1
private String	regionNamePrefix2
private MutableFastCounter	regionPut
private String	regionPutKey
private MutableFastCounter	regionScan
private String	regionScanKey
private MetricsRegionWrapper	regionWrapper
private 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 and Description
MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper, MetricsRegionAggregateSourceImpl aggregate)

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

MetricsRegionSourceImpl

public MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper,
                               MetricsRegionAggregateSourceImpl aggregate)

Method Detail

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