@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()
MetricsRegionSourceclose in interface MetricsRegionSourcepublic void updatePut()
MetricsRegionSourceupdatePut in interface MetricsRegionSourcepublic void updateDelete()
MetricsRegionSourceupdateDelete in interface MetricsRegionSourcepublic void updateGet(long getSize)
MetricsRegionSourceupdateGet in interface MetricsRegionSourcegetSize - size in bytes of the resulting key values for a getpublic void updateScan(long scanSize)
MetricsRegionSourceupdateScan in interface MetricsRegionSourcescanSize - Size in bytes of the resulting key values for a next()public void updateIncrement()
MetricsRegionSourceupdateIncrement in interface MetricsRegionSourcepublic void updateAppend()
MetricsRegionSourceupdateAppend in interface MetricsRegionSourcepublic MetricsRegionAggregateSource getAggregateSource()
MetricsRegionSourcegetAggregateSource in interface MetricsRegionSourcepublic 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.