@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()
MetricsRegionServerWrappergetClusterId in interface MetricsRegionServerWrapperpublic long getStartCode()
MetricsRegionServerWrappergetStartCode in interface MetricsRegionServerWrapperpublic String getZookeeperQuorum()
MetricsRegionServerWrappergetZookeeperQuorum in interface MetricsRegionServerWrapperpublic String getCoprocessors()
MetricsRegionServerWrappergetCoprocessors in interface MetricsRegionServerWrapperpublic String getServerName()
MetricsRegionServerWrappergetServerName in interface MetricsRegionServerWrapperpublic long getNumOnlineRegions()
MetricsRegionServerWrappergetNumOnlineRegions in interface MetricsRegionServerWrapperpublic long getTotalRequestCount()
MetricsRegionServerWrappergetTotalRequestCount in interface MetricsRegionServerWrapperpublic int getSplitQueueSize()
MetricsRegionServerWrappergetSplitQueueSize in interface MetricsRegionServerWrapperpublic int getCompactionQueueSize()
MetricsRegionServerWrappergetCompactionQueueSize in interface MetricsRegionServerWrapperpublic int getSmallCompactionQueueSize()
getSmallCompactionQueueSize in interface MetricsRegionServerWrapperpublic int getLargeCompactionQueueSize()
getLargeCompactionQueueSize in interface MetricsRegionServerWrapperpublic int getFlushQueueSize()
MetricsRegionServerWrappergetFlushQueueSize in interface MetricsRegionServerWrapperpublic long getBlockCacheCount()
MetricsRegionServerWrappergetBlockCacheCount in interface MetricsRegionServerWrapperpublic long getBlockCacheSize()
MetricsRegionServerWrappergetBlockCacheSize in interface MetricsRegionServerWrapperpublic long getBlockCacheFreeSize()
MetricsRegionServerWrappergetBlockCacheFreeSize in interface MetricsRegionServerWrapperpublic long getBlockCacheHitCount()
MetricsRegionServerWrappergetBlockCacheHitCount in interface MetricsRegionServerWrapperpublic long getBlockCachePrimaryHitCount()
MetricsRegionServerWrappergetBlockCachePrimaryHitCount in interface MetricsRegionServerWrapperpublic long getBlockCacheMissCount()
MetricsRegionServerWrappergetBlockCacheMissCount in interface MetricsRegionServerWrapperpublic long getBlockCachePrimaryMissCount()
MetricsRegionServerWrappergetBlockCachePrimaryMissCount in interface MetricsRegionServerWrapperpublic long getBlockCacheEvictedCount()
MetricsRegionServerWrappergetBlockCacheEvictedCount in interface MetricsRegionServerWrapperpublic long getBlockCachePrimaryEvictedCount()
MetricsRegionServerWrappergetBlockCachePrimaryEvictedCount in interface MetricsRegionServerWrapperpublic double getBlockCacheHitPercent()
MetricsRegionServerWrappergetBlockCacheHitPercent in interface MetricsRegionServerWrapperpublic double getBlockCacheHitCachingPercent()
MetricsRegionServerWrappergetBlockCacheHitCachingPercent in interface MetricsRegionServerWrapperpublic long getBlockCacheFailedInsertions()
MetricsRegionServerWrappergetBlockCacheFailedInsertions in interface MetricsRegionServerWrapperpublic void forceRecompute()
MetricsRegionServerWrapperforceRecompute in interface MetricsRegionServerWrapperpublic long getNumStores()
MetricsRegionServerWrappergetNumStores in interface MetricsRegionServerWrapperpublic long getNumWALFiles()
MetricsRegionServerWrappergetNumWALFiles in interface MetricsRegionServerWrapperpublic long getWALFileSize()
MetricsRegionServerWrappergetWALFileSize in interface MetricsRegionServerWrapperpublic long getNumStoreFiles()
MetricsRegionServerWrappergetNumStoreFiles in interface MetricsRegionServerWrapperpublic long getMemstoreSize()
MetricsRegionServerWrappergetMemstoreSize in interface MetricsRegionServerWrapperpublic long getStoreFileSize()
MetricsRegionServerWrappergetStoreFileSize in interface MetricsRegionServerWrapperpublic double getRequestsPerSecond()
MetricsRegionServerWrappergetRequestsPerSecond in interface MetricsRegionServerWrapperpublic long getReadRequestsCount()
MetricsRegionServerWrappergetReadRequestsCount in interface MetricsRegionServerWrapperpublic long getWriteRequestsCount()
MetricsRegionServerWrappergetWriteRequestsCount in interface MetricsRegionServerWrapperpublic long getCheckAndMutateChecksFailed()
MetricsRegionServerWrappergetCheckAndMutateChecksFailed in interface MetricsRegionServerWrapperpublic long getCheckAndMutateChecksPassed()
MetricsRegionServerWrappergetCheckAndMutateChecksPassed in interface MetricsRegionServerWrapperpublic long getStoreFileIndexSize()
MetricsRegionServerWrappergetStoreFileIndexSize in interface MetricsRegionServerWrapperpublic long getTotalStaticIndexSize()
MetricsRegionServerWrappergetTotalStaticIndexSize in interface MetricsRegionServerWrapperpublic long getTotalStaticBloomSize()
MetricsRegionServerWrappergetTotalStaticBloomSize in interface MetricsRegionServerWrapperpublic long getNumMutationsWithoutWAL()
MetricsRegionServerWrappergetNumMutationsWithoutWAL in interface MetricsRegionServerWrapperpublic long getDataInMemoryWithoutWAL()
MetricsRegionServerWrappergetDataInMemoryWithoutWAL in interface MetricsRegionServerWrapperpublic double getPercentFileLocal()
MetricsRegionServerWrappergetPercentFileLocal in interface MetricsRegionServerWrapperpublic double getPercentFileLocalSecondaryRegions()
MetricsRegionServerWrappergetPercentFileLocalSecondaryRegions in interface MetricsRegionServerWrapperpublic long getUpdatesBlockedTime()
MetricsRegionServerWrappergetUpdatesBlockedTime in interface MetricsRegionServerWrapperpublic long getFlushedCellsCount()
MetricsRegionServerWrappergetFlushedCellsCount in interface MetricsRegionServerWrapperpublic long getCompactedCellsCount()
MetricsRegionServerWrappergetCompactedCellsCount in interface MetricsRegionServerWrapperpublic long getMajorCompactedCellsCount()
MetricsRegionServerWrappergetMajorCompactedCellsCount in interface MetricsRegionServerWrapperpublic long getFlushedCellsSize()
MetricsRegionServerWrappergetFlushedCellsSize in interface MetricsRegionServerWrapperpublic long getCompactedCellsSize()
MetricsRegionServerWrappergetCompactedCellsSize in interface MetricsRegionServerWrapperpublic long getMajorCompactedCellsSize()
MetricsRegionServerWrappergetMajorCompactedCellsSize in interface MetricsRegionServerWrapperpublic long getBlockedRequestsCount()
getBlockedRequestsCount in interface MetricsRegionServerWrapperCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.