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

   1 /*
   2  * Copyright The Apache Software Foundation
   3  *
   4  * Licensed to the Apache Software Foundation (ASF) under one or more
   5  * contributor license agreements. See the NOTICE file distributed with this
   6  * work for additional information regarding copyright ownership. The ASF
   7  * licenses this file to you under the Apache License, Version 2.0 (the
   8  * "License"); you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  * http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  15  * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  16  * License for the specific language governing permissions and limitations
  17  * under the License.
  18  */
  19 package org.apache.hadoop.hbase.regionserver;
  20
  21 import org.apache.hadoop.conf.Configuration;
  22 import org.apache.yetus.audience.InterfaceAudience;
  23 import org.apache.hadoop.hbase.CompatibilitySingletonFactory;
  24
  25
  26 /**
  27  * This is the glue between the HRegion and whatever hadoop shim layer
  28  * is loaded (hbase-hadoop1-compat or hbase-hadoop2-compat).
  29  */
  30 @InterfaceAudience.Private
  31 public class MetricsRegion {
  32   private final MetricsRegionSource source;
  33   private final MetricsUserAggregate userAggregate;
  34   private MetricsRegionWrapper regionWrapper;
  35
  36   public MetricsRegion(final MetricsRegionWrapper wrapper, Configuration conf) {
  37     source = CompatibilitySingletonFactory.getInstance(MetricsRegionServerSourceFactory.class)
  38                                              .createRegion(wrapper);
  39     this.regionWrapper = wrapper;
  40     userAggregate = MetricsUserAggregateFactory.getMetricsUserAggregate(conf);
  41   }
  42
  43   public void close() {
  44     source.close();
  45   }
  46
  47   public void updatePut() {
  48     source.updatePut();
  49   }
  50
  51   public void updateDelete() {
  52     source.updateDelete();
  53   }
  54
  55   public void updateGet(final long t) {
  56     source.updateGet(t);
  57   }
  58
  59   public void updateScanTime(final long t) {
  60     source.updateScanTime(t);
  61   }
  62
  63   public void updateFilteredRecords(){
  64     userAggregate.updateFilteredReadRequests();
  65   }
  66   public void updateAppend() {
  67     source.updateAppend();
  68   }
  69
  70   public void updateIncrement() {
  71     source.updateIncrement();
  72   }
  73
  74   MetricsRegionSource getSource() {
  75     return source;
  76   }
  77
  78   public MetricsRegionWrapper getRegionWrapper() {
  79     return regionWrapper;
  80   }
  81
  82   public void updateReadRequestCount() {
  83     userAggregate.updateReadRequestCount();
  84   }
  85 }