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 java.io.IOException;
21
22 import org.apache.hadoop.hbase.classification.InterfaceAudience;
23 import org.apache.hadoop.hbase.CoordinatedStateException;
24 import org.apache.hadoop.hbase.CoordinatedStateManager;
25 import org.apache.hadoop.hbase.Server;
26 import org.apache.hadoop.hbase.TableStateManager;
27 import org.apache.hadoop.hbase.procedure.ProcedureCoordinatorRpcs;
28 import org.apache.hadoop.hbase.procedure.ProcedureMemberRpcs;
29
30
31
32
33
34
35
36 @InterfaceAudience.Private
37 public abstract class BaseCoordinatedStateManager implements CoordinatedStateManager {
38
39 @Override
40 public void initialize(Server server) {
41 }
42
43 @Override
44 public void start() {
45 }
46
47 @Override
48 public void stop() {
49 }
50
51 @Override
52 public Server getServer() {
53 return null;
54 }
55
56 @Override
57 public abstract TableStateManager getTableStateManager() throws InterruptedException,
58 CoordinatedStateException;
59
60
61
62 public abstract SplitLogWorkerCoordination getSplitLogWorkerCoordination();
63
64
65
66 public abstract SplitLogManagerCoordination getSplitLogManagerCoordination();
67
68
69
70 abstract public SplitTransactionCoordination getSplitTransactionCoordination();
71
72
73
74
75 public abstract CloseRegionCoordination getCloseRegionCoordination();
76
77
78
79
80 public abstract OpenRegionCoordination getOpenRegionCoordination();
81
82
83
84
85 public abstract RegionMergeCoordination getRegionMergeCoordination();
86
87
88
89
90 public abstract ProcedureCoordinatorRpcs
91 getProcedureCoordinatorRpcs(String procType, String coordNode) throws IOException;
92
93
94
95
96 public abstract ProcedureMemberRpcs
97 getProcedureMemberRpcs(String procType) throws IOException;
98 }