Package org.apache.hadoop.hbase.regionserver

Class MetricsRegionWrapperImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsRegionWrapperImpl

All Implemented Interfaces:

Closeable, AutoCloseable, MetricsRegionWrapper

@Private
public class MetricsRegionWrapperImpl
extends Object
implements MetricsRegionWrapper, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	MetricsRegionWrapperImpl.HRegionMetricsWrapperRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private long	avgStoreFileAge
private float	currentRegionCacheRatio
private ScheduledExecutorService	executor
private static final 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 final int	PERIOD
private Map<String,Long>	readsOnlyFromMemstore
private final HRegion	region
private ScheduledFuture<?>	regionMetricsUpdateTask
private Runnable	runnable
private long	storeFileSize
private long	storeRefCount
static final String	UNKNOWN

Constructor Summary

Constructors

Constructor	Description
MetricsRegionWrapperImpl(HRegion region)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getAvgStoreFileAge()	Returns Average age of store files under this region
long	getCpRequestCount()	Get the total number of CoprocessorService requests that have been issued against this region
float	getCurrentRegionCacheRatio()	Gets the current cache % ratio for 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()	Note that this metric is updated periodically and hence might miss some data points.
long	getMaxFlushQueueSize()	Note that this metric is updated periodically and hence might miss some data points.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

PERIOD

public static final int PERIOD

See Also:

• Constant Field Values

UNKNOWN

public static final String UNKNOWN

See Also:

• Constant Field Values

region

private final HRegion region

executor

private ScheduledExecutorService executor

runnable

private Runnable runnable

numStoreFiles

private long numStoreFiles

storeRefCount

private long storeRefCount

maxCompactedStoreFileRefCount

private long maxCompactedStoreFileRefCount

memstoreSize

private long memstoreSize

storeFileSize

private long storeFileSize

maxStoreFileAge

private long maxStoreFileAge

minStoreFileAge

private long minStoreFileAge

avgStoreFileAge

private long avgStoreFileAge

numReferenceFiles

private long numReferenceFiles

maxFlushQueueSize

private long maxFlushQueueSize

maxCompactionQueueSize

private long maxCompactionQueueSize

readsOnlyFromMemstore

private Map<String,Long> readsOnlyFromMemstore

mixedReadsOnStore

private Map<String,Long> mixedReadsOnStore

regionMetricsUpdateTask

private ScheduledFuture<?> regionMetricsUpdateTask

currentRegionCacheRatio

private float currentRegionCacheRatio

Constructor Details

MetricsRegionWrapperImpl

public MetricsRegionWrapperImpl(HRegion region)

Method Details

getTableName

public String getTableName()

Description copied from interface: MetricsRegionWrapper

Get the name of the table the region belongs to.

Specified by:

getTableName in interface MetricsRegionWrapper

Returns:

The string version of the table name.

getNamespace

public String getNamespace()

Description copied from interface: MetricsRegionWrapper

Get the name of the namespace this table is in.

Specified by:

getNamespace in interface MetricsRegionWrapper

Returns:

String version of the namespace. Can't be empty.

getRegionName

public String getRegionName()

Description copied from interface: MetricsRegionWrapper

Get the name of the region.

Specified by:

getRegionName in interface MetricsRegionWrapper

Returns:

The encoded name of the region.

getNumStores

public long getNumStores()

Description copied from interface: MetricsRegionWrapper

Get the number of stores hosted on this region server.

Specified by:

getNumStores in interface MetricsRegionWrapper

getNumStoreFiles

public long getNumStoreFiles()

Description copied from interface: MetricsRegionWrapper

Get the number of store files hosted on this region server.

Specified by:

getNumStoreFiles in interface MetricsRegionWrapper

getMemStoreSize

public long getMemStoreSize()

Description copied from interface: MetricsRegionWrapper

Get the size of the memstore on this region server.

Specified by:

getMemStoreSize in interface MetricsRegionWrapper

getStoreFileSize

public long getStoreFileSize()

Description copied from interface: MetricsRegionWrapper

Get the total size of the store files this region server is serving from.

Specified by:

getStoreFileSize in interface MetricsRegionWrapper

getCurrentRegionCacheRatio

public float getCurrentRegionCacheRatio()

Description copied from interface: MetricsRegionWrapper

Gets the current cache % ratio for this region.

Specified by:

getCurrentRegionCacheRatio in interface MetricsRegionWrapper

getStoreRefCount

public long getStoreRefCount()

Description copied from interface: MetricsRegionWrapper

Returns the number of references active on the store

Specified by:

getStoreRefCount in interface MetricsRegionWrapper

getMaxCompactedStoreFileRefCount

public long getMaxCompactedStoreFileRefCount()

Description copied from interface: MetricsRegionWrapper

Returns the max number of references active on any store file among all compacted store files that belong to this region

Specified by:

getMaxCompactedStoreFileRefCount in interface MetricsRegionWrapper

getReadRequestCount

public long getReadRequestCount()

Description copied from interface: MetricsRegionWrapper

Get the total number of read requests that have been issued against this region

Specified by:

getReadRequestCount in interface MetricsRegionWrapper

getCpRequestCount

public long getCpRequestCount()

Description copied from interface: MetricsRegionWrapper

Get the total number of CoprocessorService requests that have been issued against this region

Specified by:

getCpRequestCount in interface MetricsRegionWrapper

getFilteredReadRequestCount

public long getFilteredReadRequestCount()

Description copied from interface: MetricsRegionWrapper

Get the total number of filtered read requests that have been issued against this region

Specified by:

getFilteredReadRequestCount in interface MetricsRegionWrapper

getWriteRequestCount

public long getWriteRequestCount()

Description copied from interface: MetricsRegionWrapper

Get the total number of mutations that have been issued against this region.

Specified by:

getWriteRequestCount in interface MetricsRegionWrapper

getNumFilesCompacted

public long getNumFilesCompacted()

Specified by:

getNumFilesCompacted in interface MetricsRegionWrapper

getNumBytesCompacted

public long getNumBytesCompacted()

Specified by:

getNumBytesCompacted in interface MetricsRegionWrapper

getNumCompactionsCompleted

public long getNumCompactionsCompleted()

Specified by:

getNumCompactionsCompleted in interface MetricsRegionWrapper

getLastMajorCompactionAge

public long getLastMajorCompactionAge()

Description copied from interface: MetricsRegionWrapper

Returns Age of the last major compaction

Specified by:

getLastMajorCompactionAge in interface MetricsRegionWrapper

getTotalRequestCount

public long getTotalRequestCount()

Specified by:

getTotalRequestCount in interface MetricsRegionWrapper

getNumCompactionsFailed

public long getNumCompactionsFailed()

Description copied from interface: MetricsRegionWrapper

Returns the total number of compactions that have been reported as failed on this region. Note that a given compaction can be reported as both completed and failed if an exception is thrown in the processing after HRegion.compact().

Specified by:

getNumCompactionsFailed in interface MetricsRegionWrapper

getNumCompactionsQueued

public long getNumCompactionsQueued()

Description copied from interface: MetricsRegionWrapper

Returns the total number of compactions that are currently queued(or being executed) at point in time

Specified by:

getNumCompactionsQueued in interface MetricsRegionWrapper

getNumFlushesQueued

public long getNumFlushesQueued()

Description copied from interface: MetricsRegionWrapper

Returns the total number of flushes currently queued(being executed) for this region at point in time

Specified by:

getNumFlushesQueued in interface MetricsRegionWrapper

getMaxCompactionQueueSize

public long getMaxCompactionQueueSize()

Description copied from interface: MetricsRegionWrapper

Note that this metric is updated periodically and hence might miss some data points.

Specified by:

getMaxCompactionQueueSize in interface MetricsRegionWrapper

Returns:

the max number of compactions queued for this region

getMaxFlushQueueSize

public long getMaxFlushQueueSize()

Description copied from interface: MetricsRegionWrapper

Note that this metric is updated periodically and hence might miss some data points.

Specified by:

getMaxFlushQueueSize in interface MetricsRegionWrapper

Returns:

the max number of flushes queued for this region

getMaxStoreFileAge

public long getMaxStoreFileAge()

Description copied from interface: MetricsRegionWrapper

Returns Max age of store files under this region

Specified by:

getMaxStoreFileAge in interface MetricsRegionWrapper

getMinStoreFileAge

public long getMinStoreFileAge()

Description copied from interface: MetricsRegionWrapper

Returns Min age of store files under this region

Specified by:

getMinStoreFileAge in interface MetricsRegionWrapper

getAvgStoreFileAge

public long getAvgStoreFileAge()

Description copied from interface: MetricsRegionWrapper

Returns Average age of store files under this region

Specified by:

getAvgStoreFileAge in interface MetricsRegionWrapper

getNumReferenceFiles

public long getNumReferenceFiles()

Description copied from interface: MetricsRegionWrapper

Returns Number of reference files under this region

Specified by:

getNumReferenceFiles in interface MetricsRegionWrapper

getRegionHashCode

public int getRegionHashCode()

Specified by:

getRegionHashCode in interface MetricsRegionWrapper

getMemstoreOnlyRowReadsCount

public Map<String,Long> getMemstoreOnlyRowReadsCount()

Description copied from interface: MetricsRegionWrapper

Returns the number of row reads completely on memstore per store

Specified by:

getMemstoreOnlyRowReadsCount in interface MetricsRegionWrapper

getMixedRowReadsCount

public Map<String,Long> getMixedRowReadsCount()

Description copied from interface: MetricsRegionWrapper

Returns the number of row reads on memstore and file per store

Specified by:

getMixedRowReadsCount in interface MetricsRegionWrapper

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getReplicaId

public int getReplicaId()

Get the replica id of this region.

Specified by:

getReplicaId in interface MetricsRegionWrapper