1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.regionserver;
19
20 import java.io.IOException;
21 import java.util.ArrayList;
22 import java.util.List;
23 import java.util.UUID;
24
25 import org.apache.hadoop.hbase.classification.InterfaceAudience;
26 import org.apache.hadoop.hbase.classification.InterfaceStability;
27 import org.apache.hadoop.hbase.HBaseInterfaceAudience;
28 import org.apache.hadoop.hbase.client.Durability;
29 import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
30
31 import com.google.protobuf.Message;
32
33
34
35
36 @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
37 @InterfaceStability.Evolving
38 public abstract class BaseRowProcessor<S extends Message,T extends Message>
39 implements RowProcessor<S,T> {
40
41 @Override
42 public void preProcess(HRegion region, WALEdit walEdit) throws IOException {
43 }
44
45 @Override
46 public void preBatchMutate(HRegion region, WALEdit walEdit) throws IOException {
47 }
48
49 @Override
50 public void postBatchMutate(HRegion region) throws IOException {
51 }
52
53 @Override
54 public void postProcess(HRegion region, WALEdit walEdit, boolean success) throws IOException {
55 }
56
57 @Override
58 public List<UUID> getClusterIds() {
59 return new ArrayList<UUID>();
60 }
61
62 @Override
63 public String getName() {
64 return this.getClass().getSimpleName().toLowerCase();
65 }
66
67 @Override
68 public Durability useDurability() {
69 return Durability.USE_DEFAULT;
70 }
71 }