@InterfaceAudience.Private public class MetricsRegionWrapperImpl extends Object implements MetricsRegionWrapper, Closeable
Modifier and Type | Class and Description |
---|---|
class |
MetricsRegionWrapperImpl.HRegionMetricsWrapperRunnable |
Modifier and Type | Field and Description |
---|---|
private long |
avgStoreFileAge |
private ScheduledExecutorService |
executor |
private static org.slf4j.Logger |
LOG |
private long |
maxCompactedStoreFileRefCount |
private long |
maxCompactionQueueSize |
private long |
maxFlushQueueSize |
private long |
maxStoreFileAge |
private long |
memstoreSize |
private long |
minStoreFileAge |
private Map<String,Long> |
mixedReadsOnStore |
private long |
numReferenceFiles |
private long |
numStoreFiles |
static int |
PERIOD |
private Map<String,Long> |
readsOnlyFromMemstore |
private HRegion |
region |
private ScheduledFuture<?> |
regionMetricsUpdateTask |
private Runnable |
runnable |
private long |
storeFileSize |
private long |
storeRefCount |
static String |
UNKNOWN |
Constructor and Description |
---|
MetricsRegionWrapperImpl(HRegion region) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
getAvgStoreFileAge()
Returns Average age of store files under this region
|
long |
getFilteredReadRequestCount()
Get the total number of filtered read requests that have been issued against this region
|
long |
getLastMajorCompactionAge()
Returns Age of the last major compaction
|
long |
getMaxCompactedStoreFileRefCount()
Returns the max number of references active on any store file among all compacted store files
that belong to this region
|
long |
getMaxCompactionQueueSize() |
long |
getMaxFlushQueueSize() |
long |
getMaxStoreFileAge()
Returns Max age of store files under this region
|
Map<String,Long> |
getMemstoreOnlyRowReadsCount()
Returns the number of row reads completely on memstore per store
|
long |
getMemStoreSize()
Get the size of the memstore on this region server.
|
long |
getMinStoreFileAge()
Returns Min age of store files under this region
|
Map<String,Long> |
getMixedRowReadsCount()
Returns the number of row reads on memstore and file per store
|
String |
getNamespace()
Get the name of the namespace this table is in.
|
long |
getNumBytesCompacted() |
long |
getNumCompactionsCompleted() |
long |
getNumCompactionsFailed()
Returns the total number of compactions that have been reported as failed on this region.
|
long |
getNumCompactionsQueued()
Returns the total number of compactions that are currently queued(or being executed) at point
in time
|
long |
getNumFilesCompacted() |
long |
getNumFlushesQueued()
Returns the total number of flushes currently queued(being executed) for this region at point
in time
|
long |
getNumReferenceFiles()
Returns Number of reference files under this region
|
long |
getNumStoreFiles()
Get the number of store files hosted on this region server.
|
long |
getNumStores()
Get the number of stores hosted on this region server.
|
long |
getReadRequestCount()
Get the total number of read requests that have been issued against this region
|
int |
getRegionHashCode() |
String |
getRegionName()
Get the name of the region.
|
int |
getReplicaId()
Get the replica id of this region.
|
long |
getStoreFileSize()
Get the total size of the store files this region server is serving from.
|
long |
getStoreRefCount()
Returns the number of references active on the store
|
String |
getTableName()
Get the name of the table the region belongs to.
|
long |
getTotalRequestCount() |
long |
getWriteRequestCount()
Get the total number of mutations that have been issued against this region.
|
private static final org.slf4j.Logger LOG
public static final int PERIOD
public static final String UNKNOWN
private ScheduledExecutorService executor
private long numStoreFiles
private long storeRefCount
private long maxCompactedStoreFileRefCount
private long memstoreSize
private long storeFileSize
private long maxStoreFileAge
private long minStoreFileAge
private long avgStoreFileAge
private long numReferenceFiles
private long maxFlushQueueSize
private long maxCompactionQueueSize
private Map<String,Long> readsOnlyFromMemstore
private Map<String,Long> mixedReadsOnStore
private ScheduledFuture<?> regionMetricsUpdateTask
public MetricsRegionWrapperImpl(HRegion region)
public String getTableName()
MetricsRegionWrapper
getTableName
in interface MetricsRegionWrapper
public String getNamespace()
MetricsRegionWrapper
getNamespace
in interface MetricsRegionWrapper
public String getRegionName()
MetricsRegionWrapper
getRegionName
in interface MetricsRegionWrapper
public long getNumStores()
MetricsRegionWrapper
getNumStores
in interface MetricsRegionWrapper
public long getNumStoreFiles()
MetricsRegionWrapper
getNumStoreFiles
in interface MetricsRegionWrapper
public long getMemStoreSize()
MetricsRegionWrapper
getMemStoreSize
in interface MetricsRegionWrapper
public long getStoreFileSize()
MetricsRegionWrapper
getStoreFileSize
in interface MetricsRegionWrapper
public long getStoreRefCount()
MetricsRegionWrapper
getStoreRefCount
in interface MetricsRegionWrapper
public long getMaxCompactedStoreFileRefCount()
MetricsRegionWrapper
getMaxCompactedStoreFileRefCount
in interface MetricsRegionWrapper
public long getReadRequestCount()
MetricsRegionWrapper
getReadRequestCount
in interface MetricsRegionWrapper
public long getFilteredReadRequestCount()
MetricsRegionWrapper
getFilteredReadRequestCount
in interface MetricsRegionWrapper
public long getWriteRequestCount()
MetricsRegionWrapper
getWriteRequestCount
in interface MetricsRegionWrapper
public long getNumFilesCompacted()
getNumFilesCompacted
in interface MetricsRegionWrapper
public long getNumBytesCompacted()
getNumBytesCompacted
in interface MetricsRegionWrapper
public long getNumCompactionsCompleted()
getNumCompactionsCompleted
in interface MetricsRegionWrapper
public long getLastMajorCompactionAge()
MetricsRegionWrapper
getLastMajorCompactionAge
in interface MetricsRegionWrapper
public long getTotalRequestCount()
getTotalRequestCount
in interface MetricsRegionWrapper
public long getNumCompactionsFailed()
MetricsRegionWrapper
HRegion.compact()
.getNumCompactionsFailed
in interface MetricsRegionWrapper
public long getNumCompactionsQueued()
MetricsRegionWrapper
getNumCompactionsQueued
in interface MetricsRegionWrapper
public long getNumFlushesQueued()
MetricsRegionWrapper
getNumFlushesQueued
in interface MetricsRegionWrapper
public long getMaxCompactionQueueSize()
getMaxCompactionQueueSize
in interface MetricsRegionWrapper
public long getMaxFlushQueueSize()
getMaxFlushQueueSize
in interface MetricsRegionWrapper
public long getMaxStoreFileAge()
MetricsRegionWrapper
getMaxStoreFileAge
in interface MetricsRegionWrapper
public long getMinStoreFileAge()
MetricsRegionWrapper
getMinStoreFileAge
in interface MetricsRegionWrapper
public long getAvgStoreFileAge()
MetricsRegionWrapper
getAvgStoreFileAge
in interface MetricsRegionWrapper
public long getNumReferenceFiles()
MetricsRegionWrapper
getNumReferenceFiles
in interface MetricsRegionWrapper
public int getRegionHashCode()
getRegionHashCode
in interface MetricsRegionWrapper
public Map<String,Long> getMemstoreOnlyRowReadsCount()
MetricsRegionWrapper
getMemstoreOnlyRowReadsCount
in interface MetricsRegionWrapper
public Map<String,Long> getMixedRowReadsCount()
MetricsRegionWrapper
getMixedRowReadsCount
in interface MetricsRegionWrapper
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public int getReplicaId()
getReplicaId
in interface MetricsRegionWrapper
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.