You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by op...@apache.org on 2019/03/06 02:41:06 UTC
[hbase] 13/17: HBASE-15728 (addendum) Add remaining per-table
region / store / flush / compaction related metrics
This is an automated email from the ASF dual-hosted git repository.
openinx pushed a commit to branch HBASE-21879
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 0120f9380acec4f02d93b6bff19a5a9396df9226
Author: xcang <xc...@salesforce.com>
AuthorDate: Thu Sep 6 00:55:57 2018 -0700
HBASE-15728 (addendum) Add remaining per-table region / store / flush / compaction related metrics
Signed-off-by: Guanghao Zhang <zg...@apache.org>
---
.../hadoop/hbase/regionserver/MetricsTableSourceImpl.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
index 3da16b8..5e789d5 100644
--- a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
+++ b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsTableSourceImpl.java
@@ -367,19 +367,19 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
}
@Override
- public void updateFlushMemstoreSize(long bytes) {
+ public synchronized void updateFlushMemstoreSize(long bytes) {
flushMemstoreSizeHisto.add(bytes);
flushedMemstoreBytes.incr(bytes);
}
@Override
- public void updateFlushOutputSize(long bytes) {
+ public synchronized void updateFlushOutputSize(long bytes) {
flushOutputSizeHisto.add(bytes);
flushedOutputBytes.incr(bytes);
}
@Override
- public void updateCompactionTime(boolean isMajor, long t) {
+ public synchronized void updateCompactionTime(boolean isMajor, long t) {
compactionTimeHisto.add(t);
if (isMajor) {
majorCompactionTimeHisto.add(t);
@@ -387,7 +387,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
}
@Override
- public void updateCompactionInputFileCount(boolean isMajor, long c) {
+ public synchronized void updateCompactionInputFileCount(boolean isMajor, long c) {
compactionInputFileCountHisto.add(c);
if (isMajor) {
majorCompactionInputFileCountHisto.add(c);
@@ -395,7 +395,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
}
@Override
- public void updateCompactionInputSize(boolean isMajor, long bytes) {
+ public synchronized void updateCompactionInputSize(boolean isMajor, long bytes) {
compactionInputSizeHisto.add(bytes);
compactedInputBytes.incr(bytes);
if (isMajor) {
@@ -405,7 +405,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
}
@Override
- public void updateCompactionOutputFileCount(boolean isMajor, long c) {
+ public synchronized void updateCompactionOutputFileCount(boolean isMajor, long c) {
compactionOutputFileCountHisto.add(c);
if (isMajor) {
majorCompactionOutputFileCountHisto.add(c);
@@ -413,7 +413,7 @@ public class MetricsTableSourceImpl implements MetricsTableSource {
}
@Override
- public void updateCompactionOutputSize(boolean isMajor, long bytes) {
+ public synchronized void updateCompactionOutputSize(boolean isMajor, long bytes) {
compactionOutputSizeHisto.add(bytes);
compactedOutputBytes.incr(bytes);
if (isMajor) {