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 QualifierFilter extends CompareFilter {
51
52
53
54
55
56
57 public QualifierFilter(final CompareOp op,
58 final ByteArrayComparable qualifierComparator) {
59 super(op, qualifierComparator);
60 }
61
62 @Override
63 public ReturnCode filterKeyValue(Cell v) {
64 int qualifierLength = v.getQualifierLength();
65 if (qualifierLength > 0) {
66 if (doCompare(this.compareOp, this.comparator, v.getQualifierArray(),
67 v.getQualifierOffset(), qualifierLength)) {
68 return ReturnCode.SKIP;
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 QualifierFilter(compareOp, comparator);
79 }
80
81
82
83
84 public byte [] toByteArray() {
85 FilterProtos.QualifierFilter.Builder builder =
86 FilterProtos.QualifierFilter.newBuilder();
87 builder.setCompareFilter(super.convert());
88 return builder.build().toByteArray();
89 }
90
91
92
93
94
95
96
97 public static QualifierFilter parseFrom(final byte [] pbBytes)
98 throws DeserializationException {
99 FilterProtos.QualifierFilter proto;
100 try {
101 proto = FilterProtos.QualifierFilter.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 QualifierFilter(valueCompareOp,valueComparator);
116 }
117
118
119
120
121
122
123 boolean areSerializedFieldsEqual(Filter o) {
124 if (o == this) return true;
125 if (!(o instanceof QualifierFilter)) return false;
126
127 return super.areSerializedFieldsEqual(o);
128 }
129 }