org.apache.hadoop.hbase.regionserver

Class MetricsTableWrapperAggregateImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsTableWrapperAggregateImpl

All Implemented Interfaces:

Closeable, AutoCloseable, MetricsTableWrapperAggregate

@InterfaceAudience.Private
public class MetricsTableWrapperAggregateImpl
extends Object
implements MetricsTableWrapperAggregate, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	MetricsTableWrapperAggregateImpl.MetricsTableValues
class	MetricsTableWrapperAggregateImpl.TableMetricsWrapperRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private ScheduledExecutorService	executor
private ConcurrentHashMap<TableName,MetricsTableWrapperAggregateImpl.MetricsTableValues>	metricsTableMap
private long	period
private HRegionServer	regionServer
private Runnable	runnable
private ScheduledFuture<?>	tableMetricsUpdateTask

Constructor Summary

Constructors

Constructor and Description
MetricsTableWrapperAggregateImpl(HRegionServer regionServer)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getMemStoresSize(String table) Get the memory store size against this table
long	getReadRequestsCount(String table) Get the number of read requests that have been issued against this table
long	getStoreFilesSize(String table) Get the store file size against this table
long	getTableSize(String table) Get the table region size against this table
long	getTotalRequestsCount(String table) Get the total number of requests that have been issued against this table
long	getWriteRequestsCount(String table) Get the number of write requests that have been issued against this table

Methods inherited from class java.lang.Object

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

Field Detail

regionServer

private final HRegionServer regionServer

executor

private ScheduledExecutorService executor

runnable

private Runnable runnable

period

private long period

tableMetricsUpdateTask

private ScheduledFuture<?> tableMetricsUpdateTask

metricsTableMap

private ConcurrentHashMap<TableName,MetricsTableWrapperAggregateImpl.MetricsTableValues> metricsTableMap

Constructor Detail

MetricsTableWrapperAggregateImpl

public MetricsTableWrapperAggregateImpl(HRegionServer regionServer)

Method Detail

getReadRequestsCount

public long getReadRequestsCount(String table)

Description copied from interface: MetricsTableWrapperAggregate

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

Specified by:

getReadRequestsCount in interface MetricsTableWrapperAggregate

getWriteRequestsCount

public long getWriteRequestsCount(String table)

Description copied from interface: MetricsTableWrapperAggregate

Get the number of write requests that have been issued against this table

Specified by:

getWriteRequestsCount in interface MetricsTableWrapperAggregate

getTotalRequestsCount

public long getTotalRequestsCount(String table)

Description copied from interface: MetricsTableWrapperAggregate

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

Specified by:

getTotalRequestsCount in interface MetricsTableWrapperAggregate

getMemStoresSize

public long getMemStoresSize(String table)

Description copied from interface: MetricsTableWrapperAggregate

Get the memory store size against this table

Specified by:

getMemStoresSize in interface MetricsTableWrapperAggregate

getStoreFilesSize

public long getStoreFilesSize(String table)

Description copied from interface: MetricsTableWrapperAggregate

Get the store file size against this table

Specified by:

getStoreFilesSize in interface MetricsTableWrapperAggregate

getTableSize

public long getTableSize(String table)

Description copied from interface: MetricsTableWrapperAggregate

Get the table region size against this table

Specified by:

getTableSize in interface MetricsTableWrapperAggregate

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException