hbase-server/src/main/java/org/apache/hadoop/hbase/master/MetricsAssignmentManager.java

   1 /**
   2  * Licensed to the Apache Software Foundation (ASF) under one
   3  * or more contributor license agreements.  See the NOTICE file
   4  * distributed with this work for additional information
   5  * regarding copyright ownership.  The ASF licenses this file
   6  * to you under the Apache License, Version 2.0 (the
   7  * "License"); you may not use this file except in compliance
   8  * with the License.  You may obtain a copy of the License at
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18
  19 package org.apache.hadoop.hbase.master;
  20
  21 import static org.apache.hadoop.hbase.master.MetricsMaster.convertToProcedureMetrics;
  22
  23 import org.apache.hadoop.hbase.CompatibilitySingletonFactory;
  24 import org.apache.hadoop.hbase.procedure2.ProcedureMetrics;
  25 import org.apache.yetus.audience.InterfaceAudience;
  26
  27 @InterfaceAudience.Private
  28 public class MetricsAssignmentManager {
  29   private final MetricsAssignmentManagerSource assignmentManagerSource;
  30
  31   private final ProcedureMetrics assignProcMetrics;
  32   private final ProcedureMetrics unassignProcMetrics;
  33   private final ProcedureMetrics moveProcMetrics;
  34   private final ProcedureMetrics reopenProcMetrics;
  35   private final ProcedureMetrics openProcMetrics;
  36   private final ProcedureMetrics closeProcMetrics;
  37   private final ProcedureMetrics splitProcMetrics;
  38   private final ProcedureMetrics mergeProcMetrics;
  39
  40   public MetricsAssignmentManager() {
  41     assignmentManagerSource = CompatibilitySingletonFactory.getInstance(
  42         MetricsAssignmentManagerSource.class);
  43
  44     assignProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getAssignMetrics());
  45     unassignProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getUnassignMetrics());
  46     moveProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getMoveMetrics());
  47     reopenProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getReopenMetrics());
  48     openProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getOpenMetrics());
  49     closeProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getCloseMetrics());
  50     splitProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getSplitMetrics());
  51     mergeProcMetrics = convertToProcedureMetrics(assignmentManagerSource.getMergeMetrics());
  52   }
  53
  54   public MetricsAssignmentManagerSource getMetricsProcSource() {
  55     return assignmentManagerSource;
  56   }
  57
  58   /**
  59    * set new value for number of regions in transition.
  60    * @param ritCount
  61    */
  62   public void updateRITCount(final int ritCount) {
  63     assignmentManagerSource.setRIT(ritCount);
  64   }
  65
  66   /**
  67    * update RIT count that are in this state for more than the threshold
  68    * as defined by the property rit.metrics.threshold.time.
  69    * @param ritCountOverThreshold
  70    */
  71   public void updateRITCountOverThreshold(final int ritCountOverThreshold) {
  72     assignmentManagerSource.setRITCountOverThreshold(ritCountOverThreshold);
  73   }
  74
  75   /**
  76    * update the timestamp for oldest region in transition metrics.
  77    * @param timestamp
  78    */
  79   public void updateRITOldestAge(final long timestamp) {
  80     assignmentManagerSource.setRITOldestAge(timestamp);
  81   }
  82
  83   /**
  84    * update the duration metrics of region is transition
  85    * @param duration
  86    */
  87   public void updateRitDuration(long duration) {
  88     assignmentManagerSource.updateRitDuration(duration);
  89   }
  90
  91   /*
  92    * TODO: Remove. This may not be required as assign and unassign operations are tracked separately
  93    * Increment the count of assignment operation (assign/unassign).
  94    */
  95   public void incrementOperationCounter() {
  96     assignmentManagerSource.incrementOperationCounter();
  97   }
  98
  99   public void updateDeadServerOpenRegions(int deadRegions) {
 100     assignmentManagerSource.updateDeadServerOpenRegions(deadRegions);
 101   }
 102
 103   public void updateUnknownServerOpenRegions(int unknownRegions) {
 104     assignmentManagerSource.updateUnknownServerOpenRegions(unknownRegions);
 105   }
 106
 107   public void updateOrphanRegionsOnRs(int orphanRegionsOnRs) {
 108     assignmentManagerSource.setOrphanRegionsOnRs(orphanRegionsOnRs);
 109   }
 110
 111   public void updateOrphanRegionsOnFs(int orphanRegionsOnFs) {
 112     assignmentManagerSource.setOrphanRegionsOnFs(orphanRegionsOnFs);
 113   }
 114
 115   public void updateInconsistentRegions(int inconsistentRegions) {
 116     assignmentManagerSource.setInconsistentRegions(inconsistentRegions);
 117   }
 118
 119   public void updateHoles(int holes) {
 120     assignmentManagerSource.setHoles(holes);
 121   }
 122
 123   public void updateOverlaps(int overlaps) {
 124     assignmentManagerSource.setOverlaps(overlaps);
 125   }
 126
 127   public void updateUnknownServerRegions(int unknownServerRegions) {
 128     assignmentManagerSource.setUnknownServerRegions(unknownServerRegions);
 129   }
 130
 131   public void updateEmptyRegionInfoRegions(int emptyRegionInfoRegions) {
 132     assignmentManagerSource.setEmptyRegionInfoRegions(emptyRegionInfoRegions);
 133   }
 134
 135   /**
 136    * @return Set of common metrics for assign procedure
 137    */
 138   public ProcedureMetrics getAssignProcMetrics() {
 139     return assignProcMetrics;
 140   }
 141
 142   /**
 143    * @return Set of common metrics for unassign procedure
 144    */
 145   public ProcedureMetrics getUnassignProcMetrics() {
 146     return unassignProcMetrics;
 147   }
 148
 149   /**
 150    * @return Set of common metrics for move procedure
 151    */
 152   public ProcedureMetrics getMoveProcMetrics() {
 153     return moveProcMetrics;
 154   }
 155
 156   /**
 157    * @return Set of common metrics for reopen procedure
 158    */
 159   public ProcedureMetrics getReopenProcMetrics() {
 160     return reopenProcMetrics;
 161   }
 162
 163   /**
 164    * @return Set of common metrics for OpenRegionProcedure
 165    */
 166   public ProcedureMetrics getOpenProcMetrics() {
 167     return openProcMetrics;
 168   }
 169
 170   /**
 171    * @return Set of common metrics for CloseRegionProcedure
 172    */
 173   public ProcedureMetrics getCloseProcMetrics() {
 174     return closeProcMetrics;
 175   }
 176
 177   /**
 178    * @return Set of common metrics for split procedure
 179    */
 180   public ProcedureMetrics getSplitProcMetrics() {
 181     return splitProcMetrics;
 182   }
 183
 184   /**
 185    * @return Set of common metrics for merge procedure
 186    */
 187   public ProcedureMetrics getMergeProcMetrics() {
 188     return mergeProcMetrics;
 189   }
 190 }