@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)
MetricsTableWrapperAggregate
getReadRequestCount
in interface MetricsTableWrapperAggregate
public Map<String,Long> getMemstoreOnlyRowReadsCount(String table)
getMemstoreOnlyRowReadsCount
in interface MetricsTableWrapperAggregate
public Map<String,Long> getMixedRowReadsCount(String table)
getMixedRowReadsCount
in interface MetricsTableWrapperAggregate
public long getCpRequestsCount(String table)
public long getFilteredReadRequestCount(String table)
MetricsTableWrapperAggregate
getFilteredReadRequestCount
in interface MetricsTableWrapperAggregate
public long getWriteRequestCount(String table)
MetricsTableWrapperAggregate
getWriteRequestCount
in interface MetricsTableWrapperAggregate
public long getTotalRequestsCount(String table)
MetricsTableWrapperAggregate
getTotalRequestsCount
in interface MetricsTableWrapperAggregate
public long getMemStoreSize(String table)
MetricsTableWrapperAggregate
getMemStoreSize
in interface MetricsTableWrapperAggregate
public long getStoreFileSize(String table)
MetricsTableWrapperAggregate
getStoreFileSize
in interface MetricsTableWrapperAggregate
public long getTableSize(String table)
MetricsTableWrapperAggregate
getTableSize
in interface MetricsTableWrapperAggregate
public long getNumRegions(String table)
MetricsTableWrapperAggregate
getNumRegions
in interface MetricsTableWrapperAggregate
public long getNumStores(String table)
MetricsTableWrapperAggregate
getNumStores
in interface MetricsTableWrapperAggregate
public long getNumStoreFiles(String table)
MetricsTableWrapperAggregate
getNumStoreFiles
in interface MetricsTableWrapperAggregate
public long getMaxStoreFileAge(String table)
getMaxStoreFileAge
in interface MetricsTableWrapperAggregate
public long getMinStoreFileAge(String table)
getMinStoreFileAge
in interface MetricsTableWrapperAggregate
public long getAvgStoreFileAge(String table)
getAvgStoreFileAge
in interface MetricsTableWrapperAggregate
public long getNumReferenceFiles(String table)
getNumReferenceFiles
in interface MetricsTableWrapperAggregate
public long getAvgRegionSize(String table)
MetricsTableWrapperAggregate
getAvgRegionSize
in interface MetricsTableWrapperAggregate
public long getCpRequestCount(String table)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.