1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.coordination;
19
20 import org.apache.hadoop.hbase.classification.InterfaceAudience;
21 import org.apache.hadoop.hbase.HBaseInterfaceAudience;
22 import org.apache.hadoop.hbase.Server;
23 import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;
24
25
26
27
28 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
29 public class ZkCoordinatedStateManager extends BaseCoordinatedStateManager {
30 protected Server server;
31 protected ZooKeeperWatcher watcher;
32 protected SplitLogWorkerCoordination splitLogWorkerCoordination;
33 protected SplitLogManagerCoordination splitLogManagerCoordination;
34
35 @Override
36 public void initialize(Server server) {
37 this.server = server;
38 this.watcher = server.getZooKeeper();
39 splitLogWorkerCoordination = new ZkSplitLogWorkerCoordination(this, watcher);
40 splitLogManagerCoordination = new ZKSplitLogManagerCoordination(this, watcher);
41
42 }
43
44 @Override
45 public Server getServer() {
46 return server;
47 }
48
49 @Override
50 public SplitLogWorkerCoordination getSplitLogWorkerCoordination() {
51 return splitLogWorkerCoordination;
52 }
53 @Override
54 public SplitLogManagerCoordination getSplitLogManagerCoordination() {
55 return splitLogManagerCoordination;
56 }
57 }