1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.hadoop.hbase.coprocessor;
21
22 import java.io.IOException;
23 import java.util.List;
24
25 import org.apache.hadoop.hbase.classification.InterfaceAudience;
26 import org.apache.hadoop.hbase.classification.InterfaceStability;
27 import org.apache.hadoop.hbase.CellScanner;
28 import org.apache.hadoop.hbase.CoprocessorEnvironment;
29 import org.apache.hadoop.hbase.HBaseInterfaceAudience;
30 import org.apache.hadoop.hbase.client.Mutation;
31 import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry;
32 import org.apache.hadoop.hbase.regionserver.Region;
33 import org.apache.hadoop.hbase.replication.ReplicationEndpoint;
34
35
36
37
38
39
40 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
41 @InterfaceStability.Evolving
42 public class BaseRegionServerObserver implements RegionServerObserver {
43
44 @Override
45 public void preStopRegionServer(ObserverContext<RegionServerCoprocessorEnvironment> env)
46 throws IOException { }
47
48 @Override
49 public void start(CoprocessorEnvironment env) throws IOException { }
50
51 @Override
52 public void stop(CoprocessorEnvironment env) throws IOException { }
53
54 @Override
55 public void preMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx, Region regionA,
56 Region regionB) throws IOException { }
57
58 @Override
59 public void postMerge(ObserverContext<RegionServerCoprocessorEnvironment> c, Region regionA,
60 Region regionB, Region mergedRegion) throws IOException { }
61
62 @Override
63 public void preMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
64 Region regionA, Region regionB, List<Mutation> metaEntries) throws IOException { }
65
66 @Override
67 public void postMergeCommit(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
68 Region regionA, Region regionB, Region mergedRegion) throws IOException { }
69
70 @Override
71 public void preRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
72 Region regionA, Region regionB) throws IOException { }
73
74 @Override
75 public void postRollBackMerge(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
76 Region regionA, Region regionB) throws IOException { }
77
78 @Override
79 public void preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
80 throws IOException { }
81
82 @Override
83 public void postRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
84 throws IOException { }
85
86 @Override
87 public ReplicationEndpoint postCreateReplicationEndPoint(
88 ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) {
89 return endpoint;
90 }
91
92 @Override
93 public void preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
94 List<WALEntry> entries, CellScanner cells) throws IOException { }
95
96 @Override
97 public void postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
98 List<WALEntry> entries, CellScanner cells) throws IOException { }
99 }