Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-15728 (addendum) Add remaining per-table region / store / flush / compaction related metrics 

Signed-off-by: Guanghao Zhang <zghao@apache.org>
This commit is contained in:
xcang 2018-09-06 00:55:57 -07:00 committed by Guanghao Zhang
parent c9804758d1
commit c8067aaa64
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
View File

@ -367,19 +367,19 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
} }
@Override @Override
public void updateFlushMemstoreSize(long bytes) { public synchronized void updateFlushMemstoreSize(long bytes) {
flushMemstoreSizeHisto.add(bytes); flushMemstoreSizeHisto.add(bytes);
flushedMemstoreBytes.incr(bytes); flushedMemstoreBytes.incr(bytes);
} }
@Override @Override
public void updateFlushOutputSize(long bytes) { public synchronized void updateFlushOutputSize(long bytes) {
flushOutputSizeHisto.add(bytes); flushOutputSizeHisto.add(bytes);
flushedOutputBytes.incr(bytes); flushedOutputBytes.incr(bytes);
} }
@Override @Override
public void updateCompactionTime(boolean isMajor, long t) { public synchronized void updateCompactionTime(boolean isMajor, long t) {
compactionTimeHisto.add(t); compactionTimeHisto.add(t);
if (isMajor) { if (isMajor) {
majorCompactionTimeHisto.add(t); majorCompactionTimeHisto.add(t);
@ -387,7 +387,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
} }
@Override @Override
public void updateCompactionInputFileCount(boolean isMajor, long c) { public synchronized void updateCompactionInputFileCount(boolean isMajor, long c) {
compactionInputFileCountHisto.add(c); compactionInputFileCountHisto.add(c);
if (isMajor) { if (isMajor) {
majorCompactionInputFileCountHisto.add(c); majorCompactionInputFileCountHisto.add(c);
@ -395,7 +395,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
} }
@Override @Override
public void updateCompactionInputSize(boolean isMajor, long bytes) { public synchronized void updateCompactionInputSize(boolean isMajor, long bytes) {
compactionInputSizeHisto.add(bytes); compactionInputSizeHisto.add(bytes);
compactedInputBytes.incr(bytes); compactedInputBytes.incr(bytes);
if (isMajor) { if (isMajor) {
@ -405,7 +405,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
} }
@Override @Override
public void updateCompactionOutputFileCount(boolean isMajor, long c) { public synchronized void updateCompactionOutputFileCount(boolean isMajor, long c) {
compactionOutputFileCountHisto.add(c); compactionOutputFileCountHisto.add(c);
if (isMajor) { if (isMajor) {
majorCompactionOutputFileCountHisto.add(c); majorCompactionOutputFileCountHisto.add(c);
@ -413,7 +413,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
} }
@Override @Override
public void updateCompactionOutputSize(boolean isMajor, long bytes) { public synchronized void updateCompactionOutputSize(boolean isMajor, long bytes) {
compactionOutputSizeHisto.add(bytes); compactionOutputSizeHisto.add(bytes);
compactedOutputBytes.incr(bytes); compactedOutputBytes.incr(bytes);
if (isMajor) { if (isMajor) {