@InterfaceAudience.Private class MetricsRegionServerWrapperImpl extends Object implements MetricsRegionServerWrapper
Modifier and Type | Class and Description |
---|---|
class |
MetricsRegionServerWrapperImpl.RegionServerMetricsWrapperRunnable
This is the runnable that will be executed on the executor every PERIOD number of seconds
It will take metrics/numbers from all of the regions and use them to compute point in
time metrics.
|
Constructor and Description |
---|
MetricsRegionServerWrapperImpl(HRegionServer regionServer) |
Modifier and Type | Method and Description |
---|---|
void |
forceRecompute()
Force a re-computation of the metrics.
|
long |
getBlockCacheCount()
Get the number of items in the block cache.
|
long |
getBlockCacheEvictedCount()
Get the number of items evicted from the block cache.
|
long |
getBlockCacheFailedInsertions()
Number of cache insertions that failed.
|
long |
getBlockCacheFreeSize()
Get the size (in bytes) of the block cache that is free.
|
double |
getBlockCacheHitCachingPercent()
Get the percent of requests with the block cache turned on that hit the block cache.
|
long |
getBlockCacheHitCount()
Get the count of hits to the block cache
|
double |
getBlockCacheHitPercent()
Get the percent of all requests that hit the block cache.
|
long |
getBlockCacheMissCount()
Get the count of misses to the block cache.
|
long |
getBlockCachePrimaryEvictedCount()
Get the number of items evicted from primary replica in the block cache.
|
long |
getBlockCachePrimaryHitCount()
Get the count of hits to primary replica in the block cache
|
long |
getBlockCachePrimaryMissCount()
Get the count of misses to primary replica in the block cache.
|
long |
getBlockCacheSize()
Get the total size (in bytes) of the block cache.
|
long |
getBlockedRequestsCount() |
long |
getCheckAndMutateChecksFailed()
Get the number of CAS operations that failed.
|
long |
getCheckAndMutateChecksPassed()
Get the number of CAS operations that passed.
|
String |
getClusterId()
Get the Cluster ID
|
long |
getCompactedCellsCount()
Get the number of cells processed during minor compactions.
|
long |
getCompactedCellsSize()
Get the total amount of data processed during minor compactions, in bytes.
|
int |
getCompactionQueueSize()
Get the size of the compaction queue
|
String |
getCoprocessors()
Get the co-processors
|
long |
getDataInMemoryWithoutWAL()
Ammount of data in the memstore but not in the WAL because mutations explicitly had their
WAL turned off.
|
long |
getFlushedCellsCount()
Get the number of cells flushed to disk.
|
long |
getFlushedCellsSize()
Get the total amount of data flushed to disk, in bytes.
|
int |
getFlushQueueSize()
Get the size of the flush queue.
|
int |
getLargeCompactionQueueSize() |
long |
getMajorCompactedCellsCount()
Get the number of cells processed during major compactions.
|
long |
getMajorCompactedCellsSize()
Get the total amount of data processed during major compactions, in bytes.
|
long |
getMemstoreSize()
Get the size of the memstore on this region server.
|
long |
getNumMutationsWithoutWAL()
Number of mutations received with WAL explicitly turned off.
|
long |
getNumOnlineRegions()
The number of online regions
|
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 |
getNumWALFiles()
Get the number of WAL files of this region server.
|
double |
getPercentFileLocal()
Get the percent of HFiles' that are local.
|
double |
getPercentFileLocalSecondaryRegions()
Get the percent of HFiles' that are local for secondary region replicas.
|
long |
getReadRequestsCount()
Get the number of read requests to regions hosted on this region server.
|
double |
getRequestsPerSecond()
Get the number of requests per second.
|
String |
getServerName()
Get ServerName
|
int |
getSmallCompactionQueueSize() |
int |
getSplitQueueSize()
Get the size of the split queue
|
long |
getStartCode()
Get HRegionServer start time
|
long |
getStoreFileIndexSize()
Get the Size (in bytes) of indexes in storefiles on disk.
|
long |
getStoreFileSize()
Get the total size of the store files this region server is serving from.
|
long |
getTotalRequestCount()
Get the total number of requests per second.
|
long |
getTotalStaticBloomSize()
Get the size (in bytes) of the static bloom filters.
|
long |
getTotalStaticIndexSize()
Get the size (in bytes) of of the static indexes including the roots.
|
long |
getUpdatesBlockedTime()
Get the amount of time that updates were blocked.
|
long |
getWALFileSize()
Get the size of WAL files of this region server.
|
long |
getWriteRequestsCount()
Get the number of write requests to regions hosted on this region server.
|
String |
getZookeeperQuorum()
Get the Zookeeper Quorum Info
|
private void |
initBlockCache()
It's possible that due to threading the block cache could not be initialized
yet (testing multiple region servers in one jvm).
|
private static final org.apache.commons.logging.Log LOG
private final HRegionServer regionServer
private BlockCache blockCache
private volatile long numStores
private volatile long numWALFiles
private volatile long walFileSize
private volatile long numStoreFiles
private volatile long memstoreSize
private volatile long storeFileSize
private volatile double requestsPerSecond
private volatile long readRequestsCount
private volatile long writeRequestsCount
private volatile long checkAndMutateChecksFailed
private volatile long checkAndMutateChecksPassed
private volatile long storefileIndexSize
private volatile long totalStaticIndexSize
private volatile long totalStaticBloomSize
private volatile long numMutationsWithoutWAL
private volatile long dataInMemoryWithoutWAL
private volatile double percentFileLocal
private volatile double percentFileLocalSecondaryRegions
private volatile long flushedCellsCount
private volatile long compactedCellsCount
private volatile long majorCompactedCellsCount
private volatile long flushedCellsSize
private volatile long compactedCellsSize
private volatile long majorCompactedCellsSize
private volatile long blockedRequestsCount
private CacheStats cacheStats
private ScheduledExecutorService executor
private Runnable runnable
private long period
public MetricsRegionServerWrapperImpl(HRegionServer regionServer)
private void initBlockCache()
public String getClusterId()
MetricsRegionServerWrapper
getClusterId
in interface MetricsRegionServerWrapper
public long getStartCode()
MetricsRegionServerWrapper
getStartCode
in interface MetricsRegionServerWrapper
public String getZookeeperQuorum()
MetricsRegionServerWrapper
getZookeeperQuorum
in interface MetricsRegionServerWrapper
public String getCoprocessors()
MetricsRegionServerWrapper
getCoprocessors
in interface MetricsRegionServerWrapper
public String getServerName()
MetricsRegionServerWrapper
getServerName
in interface MetricsRegionServerWrapper
public long getNumOnlineRegions()
MetricsRegionServerWrapper
getNumOnlineRegions
in interface MetricsRegionServerWrapper
public long getTotalRequestCount()
MetricsRegionServerWrapper
getTotalRequestCount
in interface MetricsRegionServerWrapper
public int getSplitQueueSize()
MetricsRegionServerWrapper
getSplitQueueSize
in interface MetricsRegionServerWrapper
public int getCompactionQueueSize()
MetricsRegionServerWrapper
getCompactionQueueSize
in interface MetricsRegionServerWrapper
public int getSmallCompactionQueueSize()
getSmallCompactionQueueSize
in interface MetricsRegionServerWrapper
public int getLargeCompactionQueueSize()
getLargeCompactionQueueSize
in interface MetricsRegionServerWrapper
public int getFlushQueueSize()
MetricsRegionServerWrapper
getFlushQueueSize
in interface MetricsRegionServerWrapper
public long getBlockCacheCount()
MetricsRegionServerWrapper
getBlockCacheCount
in interface MetricsRegionServerWrapper
public long getBlockCacheSize()
MetricsRegionServerWrapper
getBlockCacheSize
in interface MetricsRegionServerWrapper
public long getBlockCacheFreeSize()
MetricsRegionServerWrapper
getBlockCacheFreeSize
in interface MetricsRegionServerWrapper
public long getBlockCacheHitCount()
MetricsRegionServerWrapper
getBlockCacheHitCount
in interface MetricsRegionServerWrapper
public long getBlockCachePrimaryHitCount()
MetricsRegionServerWrapper
getBlockCachePrimaryHitCount
in interface MetricsRegionServerWrapper
public long getBlockCacheMissCount()
MetricsRegionServerWrapper
getBlockCacheMissCount
in interface MetricsRegionServerWrapper
public long getBlockCachePrimaryMissCount()
MetricsRegionServerWrapper
getBlockCachePrimaryMissCount
in interface MetricsRegionServerWrapper
public long getBlockCacheEvictedCount()
MetricsRegionServerWrapper
getBlockCacheEvictedCount
in interface MetricsRegionServerWrapper
public long getBlockCachePrimaryEvictedCount()
MetricsRegionServerWrapper
getBlockCachePrimaryEvictedCount
in interface MetricsRegionServerWrapper
public double getBlockCacheHitPercent()
MetricsRegionServerWrapper
getBlockCacheHitPercent
in interface MetricsRegionServerWrapper
public double getBlockCacheHitCachingPercent()
MetricsRegionServerWrapper
getBlockCacheHitCachingPercent
in interface MetricsRegionServerWrapper
public long getBlockCacheFailedInsertions()
MetricsRegionServerWrapper
getBlockCacheFailedInsertions
in interface MetricsRegionServerWrapper
public void forceRecompute()
MetricsRegionServerWrapper
forceRecompute
in interface MetricsRegionServerWrapper
public long getNumStores()
MetricsRegionServerWrapper
getNumStores
in interface MetricsRegionServerWrapper
public long getNumWALFiles()
MetricsRegionServerWrapper
getNumWALFiles
in interface MetricsRegionServerWrapper
public long getWALFileSize()
MetricsRegionServerWrapper
getWALFileSize
in interface MetricsRegionServerWrapper
public long getNumStoreFiles()
MetricsRegionServerWrapper
getNumStoreFiles
in interface MetricsRegionServerWrapper
public long getMemstoreSize()
MetricsRegionServerWrapper
getMemstoreSize
in interface MetricsRegionServerWrapper
public long getStoreFileSize()
MetricsRegionServerWrapper
getStoreFileSize
in interface MetricsRegionServerWrapper
public double getRequestsPerSecond()
MetricsRegionServerWrapper
getRequestsPerSecond
in interface MetricsRegionServerWrapper
public long getReadRequestsCount()
MetricsRegionServerWrapper
getReadRequestsCount
in interface MetricsRegionServerWrapper
public long getWriteRequestsCount()
MetricsRegionServerWrapper
getWriteRequestsCount
in interface MetricsRegionServerWrapper
public long getCheckAndMutateChecksFailed()
MetricsRegionServerWrapper
getCheckAndMutateChecksFailed
in interface MetricsRegionServerWrapper
public long getCheckAndMutateChecksPassed()
MetricsRegionServerWrapper
getCheckAndMutateChecksPassed
in interface MetricsRegionServerWrapper
public long getStoreFileIndexSize()
MetricsRegionServerWrapper
getStoreFileIndexSize
in interface MetricsRegionServerWrapper
public long getTotalStaticIndexSize()
MetricsRegionServerWrapper
getTotalStaticIndexSize
in interface MetricsRegionServerWrapper
public long getTotalStaticBloomSize()
MetricsRegionServerWrapper
getTotalStaticBloomSize
in interface MetricsRegionServerWrapper
public long getNumMutationsWithoutWAL()
MetricsRegionServerWrapper
getNumMutationsWithoutWAL
in interface MetricsRegionServerWrapper
public long getDataInMemoryWithoutWAL()
MetricsRegionServerWrapper
getDataInMemoryWithoutWAL
in interface MetricsRegionServerWrapper
public double getPercentFileLocal()
MetricsRegionServerWrapper
getPercentFileLocal
in interface MetricsRegionServerWrapper
public double getPercentFileLocalSecondaryRegions()
MetricsRegionServerWrapper
getPercentFileLocalSecondaryRegions
in interface MetricsRegionServerWrapper
public long getUpdatesBlockedTime()
MetricsRegionServerWrapper
getUpdatesBlockedTime
in interface MetricsRegionServerWrapper
public long getFlushedCellsCount()
MetricsRegionServerWrapper
getFlushedCellsCount
in interface MetricsRegionServerWrapper
public long getCompactedCellsCount()
MetricsRegionServerWrapper
getCompactedCellsCount
in interface MetricsRegionServerWrapper
public long getMajorCompactedCellsCount()
MetricsRegionServerWrapper
getMajorCompactedCellsCount
in interface MetricsRegionServerWrapper
public long getFlushedCellsSize()
MetricsRegionServerWrapper
getFlushedCellsSize
in interface MetricsRegionServerWrapper
public long getCompactedCellsSize()
MetricsRegionServerWrapper
getCompactedCellsSize
in interface MetricsRegionServerWrapper
public long getMajorCompactedCellsSize()
MetricsRegionServerWrapper
getMajorCompactedCellsSize
in interface MetricsRegionServerWrapper
public long getBlockedRequestsCount()
getBlockedRequestsCount
in interface MetricsRegionServerWrapper
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.