@InterfaceAudience.Private public class MetricsRegionSourceImpl extends Object implements MetricsRegionSource
Modifier and Type | Field and Description |
---|---|
private MetricsRegionAggregateSourceImpl |
agg |
private AtomicBoolean |
closed |
private int |
hashCode |
private static org.apache.commons.logging.Log |
LOG |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
regionAppend |
private String |
regionAppendKey |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
regionDelete |
private String |
regionDeleteKey |
private MutableHistogram |
regionGet |
private String |
regionGetKey |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
regionIncrement |
private String |
regionIncrementKey |
private String |
regionNamePrefix |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
regionPut |
private String |
regionPutKey |
private MutableHistogram |
regionScanNext |
private String |
regionScanNextKey |
private MetricsRegionWrapper |
regionWrapper |
private DynamicMetricsRegistry |
registry |
COMPACTIONS_COMPLETED_COUNT, COMPACTIONS_COMPLETED_DESC, COPROCESSOR_EXECUTION_STATISTICS, COPROCESSOR_EXECUTION_STATISTICS_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, SIZE_VALUE_NAME
Constructor and Description |
---|
MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper,
MetricsRegionAggregateSourceImpl aggregate) |
Modifier and Type | Method and Description |
---|---|
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 getSize)
Update count and sizes of gets.
|
void |
updateIncrement()
Update related counts of increments.
|
void |
updatePut()
Update related counts of puts.
|
void |
updateScan(long scanSize)
Update the count and sizes of resultScanner.next()
|
private static final org.apache.commons.logging.Log LOG
private AtomicBoolean closed
private MetricsRegionWrapper regionWrapper
private final MetricsRegionAggregateSourceImpl agg
private final DynamicMetricsRegistry registry
private final String regionNamePrefix
private final String regionPutKey
private final String regionDeleteKey
private final String regionGetKey
private final String regionIncrementKey
private final String regionAppendKey
private final String regionScanNextKey
private final org.apache.hadoop.metrics2.lib.MutableCounterLong regionPut
private final org.apache.hadoop.metrics2.lib.MutableCounterLong regionDelete
private final org.apache.hadoop.metrics2.lib.MutableCounterLong regionIncrement
private final org.apache.hadoop.metrics2.lib.MutableCounterLong regionAppend
private final MutableHistogram regionGet
private final MutableHistogram regionScanNext
private final int hashCode
public MetricsRegionSourceImpl(MetricsRegionWrapper regionWrapper, MetricsRegionAggregateSourceImpl aggregate)
public void close()
MetricsRegionSource
close
in interface MetricsRegionSource
public void updatePut()
MetricsRegionSource
updatePut
in interface MetricsRegionSource
public void updateDelete()
MetricsRegionSource
updateDelete
in interface MetricsRegionSource
public void updateGet(long getSize)
MetricsRegionSource
updateGet
in interface MetricsRegionSource
getSize
- size in bytes of the resulting key values for a getpublic void updateScan(long scanSize)
MetricsRegionSource
updateScan
in interface MetricsRegionSource
scanSize
- Size in bytes of the resulting key values for a next()public void updateIncrement()
MetricsRegionSource
updateIncrement
in interface MetricsRegionSource
public void updateAppend()
MetricsRegionSource
updateAppend
in interface MetricsRegionSource
public MetricsRegionAggregateSource getAggregateSource()
MetricsRegionSource
getAggregateSource
in interface MetricsRegionSource
public int compareTo(MetricsRegionSource source)
compareTo
in interface Comparable<MetricsRegionSource>
void snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, boolean ignored)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.