@InterfaceAudience.Private public class MetricsRegionSourceImpl extends Object implements 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, 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() |
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().
|
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 mills)
MetricsRegionSource
updateGet
in interface MetricsRegionSource
mills
- time for this get operation.public void updateScanTime(long mills)
MetricsRegionSource
updateScanTime
in interface MetricsRegionSource
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>
Copyright © 2007–2019 Cloudera. All rights reserved.