HBASE-27681 Refactor Table Latency Metrics

Author: thangTang

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServer.java

@@ -20,7 +20,6 @@
 import java.util.Optional;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.CompatibilitySingletonFactory;
-import org.apache.hadoop.hbase.client.RegionInfo;
 import org.apache.hadoop.hbase.metrics.Meter;
 import org.apache.hadoop.hbase.metrics.MetricRegistries;
 import org.apache.hadoop.hbase.metrics.MetricRegistry;
@@ -103,13 +102,13 @@ public MetricsRegionServerWrapper getRegionServerWrapper() {
   }
 
   public void updatePutBatch(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updatePutBatch(t));
     serverSource.updatePutBatch(t);
   }
 
   public void updatePut(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updatePut(t));
     if (t > slowMetricTime) {
       serverSource.incrSlowPut();
@@ -119,7 +118,7 @@ public void updatePut(HRegion region, long t) {
   }
 
   public void updateDelete(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateDelete(t));
     if (t > slowMetricTime) {
       serverSource.incrSlowDelete();
@@ -129,31 +128,31 @@ public void updateDelete(HRegion region, long t) {
   }
 
   public void updateDeleteBatch(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateDeleteBatch(t));
     serverSource.updateDeleteBatch(t);
   }
 
   public void updateCheckAndDelete(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateCheckAndDelete(t));
     serverSource.updateCheckAndDelete(t);
   }
 
   public void updateCheckAndPut(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateCheckAndPut(t));
     serverSource.updateCheckAndPut(t);
   }
 
   public void updateCheckAndMutate(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateCheckAndMutate(t));
     serverSource.updateCheckAndMutate(t);
   }
 
   public void updateGet(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateGet(t));
     if (t > slowMetricTime) {
       serverSource.incrSlowGet();
@@ -163,7 +162,7 @@ public void updateGet(HRegion region, long t) {
   }
 
   public void updateIncrement(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateIncrement(t));
     if (t > slowMetricTime) {
       serverSource.incrSlowIncrement();
@@ -173,7 +172,7 @@ public void updateIncrement(HRegion region, long t) {
   }
 
   public void updateAppend(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateAppend(t));
     if (t > slowMetricTime) {
       serverSource.incrSlowAppend();
@@ -188,13 +187,13 @@ public void updateReplay(long t) {
   }
 
   public void updateScanSize(HRegion region, long scanSize) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateScanSize(scanSize));
     serverSource.updateScanSize(scanSize);
   }
 
   public void updateScanTime(HRegion region, long t) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateScanTime(t));
     serverSource.updateScanTime(t);
     userAggregate.updateScanTime(t);
@@ -261,23 +260,23 @@ public void incrementRegionSizeReportingChoreTime(long time) {
   }
 
   public void updateReadQueryMeter(HRegion region, long count) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateTableReadQueryMeter(count));
     if (serverReadQueryMeter != null) {
       serverReadQueryMeter.mark(count);
     }
   }
 
   public void updateWriteQueryMeter(HRegion region, long count) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateTableWriteQueryMeter(count));
     if (serverWriteQueryMeter != null) {
       serverWriteQueryMeter.mark(count);
     }
   }
 
   public void updateWriteQueryMeter(HRegion region) {
-    Optional.ofNullable(region).flatMap(r -> r.getMetricsTableRequests())
+    Optional.ofNullable(region).flatMap(HRegion::getMetricsTableRequests)
       .ifPresent(metrics -> metrics.updateTableWriteQueryMeter());
     if (serverWriteQueryMeter != null) {
       serverWriteQueryMeter.mark();