1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.master;
19
20 import org.apache.commons.lang.StringUtils;
21 import org.apache.hadoop.hbase.classification.InterfaceAudience;
22 import org.apache.hadoop.hbase.ServerName;
23 import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;
24
25
26
27
28 @InterfaceAudience.Private
29 public class MetricsMasterWrapperImpl implements MetricsMasterWrapper {
30
31 private final HMaster master;
32
33 public MetricsMasterWrapperImpl(final HMaster master) {
34 this.master = master;
35 }
36
37 @Override
38 public double getAverageLoad() {
39 return master.getAverageLoad();
40 }
41
42 @Override
43 public long getSplitPlanCount() {
44 return master.getSplitPlanCount();
45 }
46
47 @Override
48 public long getMergePlanCount() {
49 return master.getMergePlanCount();
50 }
51
52 @Override
53 public String getClusterId() {
54 return master.getClusterId();
55 }
56
57 @Override
58 public String getZookeeperQuorum() {
59 ZooKeeperWatcher zk = master.getZooKeeper();
60 if (zk == null) {
61 return "";
62 }
63 return zk.getQuorum();
64 }
65
66 @Override
67 public String[] getCoprocessors() {
68 return master.getMasterCoprocessors();
69 }
70
71 @Override
72 public long getStartTime() {
73 return master.getMasterStartTime();
74 }
75
76 @Override
77 public long getActiveTime() {
78 return master.getMasterActiveTime();
79 }
80
81 @Override
82 public String getRegionServers() {
83 ServerManager serverManager = this.master.getServerManager();
84 if (serverManager == null) {
85 return "";
86 }
87 return StringUtils.join(serverManager.getOnlineServers().keySet(), ";");
88 }
89
90 @Override
91 public int getNumRegionServers() {
92 ServerManager serverManager = this.master.getServerManager();
93 if (serverManager == null) {
94 return 0;
95 }
96 return serverManager.getOnlineServers().size();
97 }
98
99 @Override
100 public String getDeadRegionServers() {
101 ServerManager serverManager = this.master.getServerManager();
102 if (serverManager == null) {
103 return "";
104 }
105 return StringUtils.join(serverManager.getDeadServers().copyServerNames(), ";");
106 }
107
108
109 @Override
110 public int getNumDeadRegionServers() {
111 ServerManager serverManager = this.master.getServerManager();
112 if (serverManager == null) {
113 return 0;
114 }
115 return serverManager.getDeadServers().size();
116 }
117
118 @Override
119 public String getServerName() {
120 ServerName serverName = master.getServerName();
121 if (serverName == null) {
122 return "";
123 }
124 return serverName.getServerName();
125 }
126
127 @Override
128 public boolean getIsActiveMaster() {
129 return master.isActiveMaster();
130 }
131
132 @Override
133 public long getNumWALFiles() {
134 return master.getNumWALFiles();
135 }
136
137 }