1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.master.balancer;
20
21 import org.apache.hadoop.hbase.classification.InterfaceAudience;
22 import org.apache.hadoop.hbase.metrics.BaseSourceImpl;
23 import org.apache.hadoop.metrics2.lib.MutableCounterLong;
24 import org.apache.hadoop.metrics2.lib.MutableHistogram;
25
26 @InterfaceAudience.Private
27 public class MetricsBalancerSourceImpl extends BaseSourceImpl implements MetricsBalancerSource{
28
29 private MutableHistogram blanceClusterHisto;
30 private MutableCounterLong miscCount;
31
32 public MetricsBalancerSourceImpl() {
33 this(METRICS_NAME, METRICS_DESCRIPTION, METRICS_CONTEXT, METRICS_JMX_CONTEXT);
34 }
35
36 public MetricsBalancerSourceImpl(String metricsName,
37 String metricsDescription,
38 String metricsContext, String metricsJmxContext) {
39 super(metricsName, metricsDescription, metricsContext, metricsJmxContext);
40 }
41
42
43 @Override
44 public void init() {
45 blanceClusterHisto = metricsRegistry.newTimeHistogram(BALANCE_CLUSTER);
46 miscCount = metricsRegistry.newCounter(MISC_INVOATION_COUNT, "", 0L);
47
48 }
49
50 @Override
51 public void updateBalanceCluster(long time) {
52 blanceClusterHisto.add(time);
53 }
54
55 @Override
56 public void incrMiscInvocations() {
57 miscCount.incr();
58 }
59 }