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.filter;
21
22 import java.io.IOException;
23 import java.util.ArrayList;
24
25 import org.apache.hadoop.hbase.classification.InterfaceAudience;
26 import org.apache.hadoop.hbase.classification.InterfaceStability;
27 import org.apache.hadoop.hbase.Cell;
28 import org.apache.hadoop.hbase.exceptions.DeserializationException;
29 import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
30 import org.apache.hadoop.hbase.protobuf.generated.FilterProtos;
31
32 import com.google.protobuf.InvalidProtocolBufferException;
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48 @InterfaceAudience.Public
49 @InterfaceStability.Stable
50 public class FamilyFilter extends CompareFilter {
51
52
53
54
55
56
57
58 public FamilyFilter(final CompareOp familyCompareOp,
59 final ByteArrayComparable familyComparator) {
60 super(familyCompareOp, familyComparator);
61 }
62
63 @Override
64 public ReturnCode filterKeyValue(Cell v) {
65 int familyLength = v.getFamilyLength();
66 if (familyLength > 0) {
67 if (doCompare(this.compareOp, this.comparator, v.getFamilyArray(),
68 v.getFamilyOffset(), familyLength)) {
69 return ReturnCode.NEXT_ROW;
70 }
71 }
72 return ReturnCode.INCLUDE;
73 }
74
75 public static Filter createFilterFromArguments(ArrayList<byte []> filterArguments) {
76 ArrayList<?> arguments = CompareFilter.extractArguments(filterArguments);
77 CompareOp compareOp = (CompareOp)arguments.get(0);
78 ByteArrayComparable comparator = (ByteArrayComparable)arguments.get(1);
79 return new FamilyFilter(compareOp, comparator);
80 }
81
82
83
84
85 public byte [] toByteArray() {
86 FilterProtos.FamilyFilter.Builder builder =
87 FilterProtos.FamilyFilter.newBuilder();
88 builder.setCompareFilter(super.convert());
89 return builder.build().toByteArray();
90 }
91
92
93
94
95
96
97
98 public static FamilyFilter parseFrom(final byte [] pbBytes)
99 throws DeserializationException {
100 FilterProtos.FamilyFilter proto;
101 try {
102 proto = FilterProtos.FamilyFilter.parseFrom(pbBytes);
103 } catch (InvalidProtocolBufferException e) {
104 throw new DeserializationException(e);
105 }
106 final CompareOp valueCompareOp =
107 CompareOp.valueOf(proto.getCompareFilter().getCompareOp().name());
108 ByteArrayComparable valueComparator = null;
109 try {
110 if (proto.getCompareFilter().hasComparator()) {
111 valueComparator = ProtobufUtil.toComparator(proto.getCompareFilter().getComparator());
112 }
113 } catch (IOException ioe) {
114 throw new DeserializationException(ioe);
115 }
116 return new FamilyFilter(valueCompareOp,valueComparator);
117 }
118
119
120
121
122
123
124 boolean areSerializedFieldsEqual(Filter o) {
125 if (o == this) return true;
126 if (!(o instanceof FamilyFilter)) return false;
127
128 FamilyFilter other = (FamilyFilter)o;
129 return super.areSerializedFieldsEqual(other);
130 }
131 }