@InterfaceAudience.Private public class MetricsTableWrapperAggregateImpl extends Object implements MetricsTableWrapperAggregate, Closeable
| Modifier and Type | Class and Description |
|---|---|
private static class |
MetricsTableWrapperAggregateImpl.MetricsTableValues |
class |
MetricsTableWrapperAggregateImpl.TableMetricsWrapperRunnable |
| 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 |
UNDERSCORE| Constructor and Description |
|---|
MetricsTableWrapperAggregateImpl(HRegionServer regionServer) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
long |
getAvgRegionSize(String table)
Get the average region size for this table
|
long |
getAvgStoreFileAge(String table) |
long |
getCpRequestCount(String table) |
long |
getCpRequestsCount(String table) |
long |
getFilteredReadRequestCount(String table)
Get the number of write requests that have been issued against this table
|
long |
getMaxStoreFileAge(String table) |
Map<String,Long> |
getMemstoreOnlyRowReadsCount(String table) |
long |
getMemStoreSize(String table)
Get the memory store size against this table
|
long |
getMinStoreFileAge(String table) |
Map<String,Long> |
getMixedRowReadsCount(String table) |
long |
getNumReferenceFiles(String table) |
long |
getNumRegions(String table)
Get the number of regions hosted on for this table
|
long |
getNumStoreFiles(String table)
Get the number of store files hosted for this table
|
long |
getNumStores(String table)
Get the number of stores hosted on for this table
|
long |
getReadRequestCount(String table)
Get the number of read requests that have been issued against this table
|
long |
getStoreFileSize(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 for this table
|
long |
getWriteRequestCount(String table)
Get the number of write requests that have been issued for this table
|
private final HRegionServer regionServer
private ScheduledExecutorService executor
private long period
private ScheduledFuture<?> tableMetricsUpdateTask
private ConcurrentHashMap<TableName,MetricsTableWrapperAggregateImpl.MetricsTableValues> metricsTableMap
public MetricsTableWrapperAggregateImpl(HRegionServer regionServer)
public long getReadRequestCount(String table)
MetricsTableWrapperAggregategetReadRequestCount in interface MetricsTableWrapperAggregatepublic Map<String,Long> getMemstoreOnlyRowReadsCount(String table)
getMemstoreOnlyRowReadsCount in interface MetricsTableWrapperAggregatepublic Map<String,Long> getMixedRowReadsCount(String table)
getMixedRowReadsCount in interface MetricsTableWrapperAggregatepublic long getCpRequestsCount(String table)
public long getFilteredReadRequestCount(String table)
MetricsTableWrapperAggregategetFilteredReadRequestCount in interface MetricsTableWrapperAggregatepublic long getWriteRequestCount(String table)
MetricsTableWrapperAggregategetWriteRequestCount in interface MetricsTableWrapperAggregatepublic long getTotalRequestsCount(String table)
MetricsTableWrapperAggregategetTotalRequestsCount in interface MetricsTableWrapperAggregatepublic long getMemStoreSize(String table)
MetricsTableWrapperAggregategetMemStoreSize in interface MetricsTableWrapperAggregatepublic long getStoreFileSize(String table)
MetricsTableWrapperAggregategetStoreFileSize in interface MetricsTableWrapperAggregatepublic long getTableSize(String table)
MetricsTableWrapperAggregategetTableSize in interface MetricsTableWrapperAggregatepublic long getNumRegions(String table)
MetricsTableWrapperAggregategetNumRegions in interface MetricsTableWrapperAggregatepublic long getNumStores(String table)
MetricsTableWrapperAggregategetNumStores in interface MetricsTableWrapperAggregatepublic long getNumStoreFiles(String table)
MetricsTableWrapperAggregategetNumStoreFiles in interface MetricsTableWrapperAggregatepublic long getMaxStoreFileAge(String table)
getMaxStoreFileAge in interface MetricsTableWrapperAggregatepublic long getMinStoreFileAge(String table)
getMinStoreFileAge in interface MetricsTableWrapperAggregatepublic long getAvgStoreFileAge(String table)
getAvgStoreFileAge in interface MetricsTableWrapperAggregatepublic long getNumReferenceFiles(String table)
getNumReferenceFiles in interface MetricsTableWrapperAggregatepublic long getAvgRegionSize(String table)
MetricsTableWrapperAggregategetAvgRegionSize in interface MetricsTableWrapperAggregatepublic long getCpRequestCount(String table)
public void close() throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.