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