1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.coprocessor;
20
21 import java.io.IOException;
22
23 import org.apache.hadoop.hbase.classification.InterfaceAudience;
24 import org.apache.hadoop.hbase.classification.InterfaceStability;
25 import org.apache.hadoop.hbase.CoprocessorEnvironment;
26 import org.apache.hadoop.hbase.HBaseInterfaceAudience;
27 import org.apache.hadoop.hbase.HRegionInfo;
28 import org.apache.hadoop.hbase.regionserver.wal.HLogKey;
29 import org.apache.hadoop.hbase.wal.WALKey;
30 import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
31
32
33
34
35
36
37 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
38 @InterfaceStability.Evolving
39 public class BaseWALObserver implements WALObserver {
40 @Override
41 public void start(CoprocessorEnvironment e) throws IOException { }
42
43 @Override
44 public void stop(CoprocessorEnvironment e) throws IOException { }
45
46
47
48
49 @Override
50 public boolean preWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx,
51 HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException {
52 return false;
53 }
54
55 @Override
56 public boolean preWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
57 HLogKey logKey, WALEdit logEdit) throws IOException {
58 return preWALWrite(ctx, info, (WALKey)logKey, logEdit);
59 }
60
61
62
63
64 @Override
65 public void postWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx,
66 HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException { }
67
68 @Override
69 public void postWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
70 HLogKey logKey, WALEdit logEdit) throws IOException {
71 postWALWrite(ctx, info, (WALKey)logKey, logEdit);
72 }
73 }