| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/ |
| H A D | InclusiveStopFilter.java | 43 public class InclusiveStopFilter extends FilterBase { class
47 public InclusiveStopFilter(final byte [] stopRowKey) { in InclusiveStopFilter() method in InclusiveStopFilter
94 return new InclusiveStopFilter(stopRowKey); in createFilterFromArguments()
101 FilterProtos.InclusiveStopFilter.Builder builder = in toByteArray()
102 FilterProtos.InclusiveStopFilter.newBuilder(); in toByteArray()
113 public static InclusiveStopFilter parseFrom(final byte [] pbBytes) in parseFrom()
115 FilterProtos.InclusiveStopFilter proto; in parseFrom()
117 proto = FilterProtos.InclusiveStopFilter.parseFrom(pbBytes); in parseFrom()
121 return new InclusiveStopFilter(proto.hasStopRowKey()?proto.getStopRowKey().toByteArray():null); in parseFrom()
131 if (!(o instanceof InclusiveStopFilter)) return false; in areSerializedFieldsEqual()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/ |
| H A D | TestInclusiveStopFilter.java | 44 mainFilter = new InclusiveStopFilter(STOP_ROW); in setUp()
66 Filter newFilter = InclusiveStopFilter.parseFrom(buffer); in testSerialization()
|
| H A D | TestParseFilter.java | 201 InclusiveStopFilter inclusiveStopFilter = in testInclusiveStopFilter()
202 doTestFilter(filterString, InclusiveStopFilter.class); in testInclusiveStopFilter()
600 InclusiveStopFilter inclusiveStopFilter = in testUnescapedQuote1()
601 doTestFilter(filterString, InclusiveStopFilter.class); in testUnescapedQuote1()
609 InclusiveStopFilter inclusiveStopFilter = in testUnescapedQuote2()
610 doTestFilter(filterString, InclusiveStopFilter.class); in testUnescapedQuote2()
618 InclusiveStopFilter inclusiveStopFilter = in testUnescapedQuote3()
619 doTestFilter(filterString, InclusiveStopFilter.class); in testUnescapedQuote3()
|
| H A D | TestFilterSerialization.java | 167 InclusiveStopFilter inclusiveStopFilter = new InclusiveStopFilter(null); in testInclusiveStopFilter()
172 inclusiveStopFilter = new InclusiveStopFilter(Bytes.toBytes("inclusiveStopFilter")); in testInclusiveStopFilter()
|
| H A D | TestFilterList.java | 303 flist.addFilter(new InclusiveStopFilter(r1)); in testFilterListWithInclusiveStopFilteMustPassOne()
|
| H A D | TestFilter.java | 700 s.setFilter(new InclusiveStopFilter(Bytes.toBytes("testRowOne-3"))); in testInclusiveStopFilter()
715 s.setFilter(new InclusiveStopFilter(Bytes.toBytes("testRowTwo-3"))); in testInclusiveStopFilter()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/ |
| H A D | ScannerModel.java | 53 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
230 InclusiveStopFilter, enumConstant
291 case InclusiveStopFilter: in FilterModel()
293 Base64.encodeBytes(((InclusiveStopFilter)filter).getStopRowKey()); in FilterModel()
396 case InclusiveStopFilter: in build()
397 filter = new InclusiveStopFilter(Base64.decode(value)); in build()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/test/java/org/apache/hadoop/hbase/client/ |
| H A D | TestOperation.java | 50 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
119 private static InclusiveStopFilter IS_FILTER =
120 new InclusiveStopFilter(STOP_ROW_KEY.getBytes());
|
| /dports/databases/hbase/hbase-1.2.1/bin/ |
| H A D | region_mover.rb | 34 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
103 scan.setFilter(FilterList.new(FirstKeyOnlyFilter.new(),InclusiveStopFilter.new(r.getStartKey())))
|
| /dports/databases/hbase/hbase-1.2.1/hbase-protocol/src/main/protobuf/ |
| H A D | Filter.proto | 97 message InclusiveStopFilter { message
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | TestScanner.java | 55 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
217 newFilter = new WhileMatchFilter(new InclusiveStopFilter(stopRow)); in testFilters()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ |
| H A D | FilterProtos.java | 7951 public static final class InclusiveStopFilter extends class in FilterProtos
7961 private static final InclusiveStopFilter defaultInstance;
7962 public static InclusiveStopFilter getDefaultInstance() { in getDefaultInstance()
7966 public InclusiveStopFilter getDefaultInstanceForType() { in getDefaultInstanceForType()
7976 private InclusiveStopFilter( in InclusiveStopFilter() method in FilterProtos.InclusiveStopFilter
8028 public static com.google.protobuf.Parser<InclusiveStopFilter> PARSER =
8029 new com.google.protobuf.AbstractParser<InclusiveStopFilter>() {
8030 public InclusiveStopFilter parsePartialFrom(
8034 return new InclusiveStopFilter(input, extensionRegistry);
8111 ….generated.FilterProtos.InclusiveStopFilter other = (org.apache.hadoop.hbase.protobuf.generated.Fi… in equals()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-rest/src/test/java/org/apache/hadoop/hbase/rest/ |
| H A D | TestScannersWithFilters.java | 46 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
470 s.setFilter(new InclusiveStopFilter(Bytes.toBytes("testRowOne-3"))); in testInclusiveStopFilter()
485 s.setFilter(new InclusiveStopFilter(Bytes.toBytes("testRowTwo-3"))); in testInclusiveStopFilter()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/ |
| H A D | HbaseObjectWritableFor96Migration.java | 73 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
216 addToMap(InclusiveStopFilter.class, code++); in addToMap()
|
| /dports/databases/hbase/hbase-1.2.1/src/main/asciidoc/_chapters/ |
| H A D | thrift_filter_language.adoc | 238 InclusiveStopFilter::
|
| H A D | datamodel.adoc | 314 …ase.apache.org/apidocs/org/apache/hadoop/hbase/filter/InclusiveStopFilter.html[InclusiveStopFilter…
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/client/ |
| H A D | TestFromClientSide.java | 75 import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
6184 scan.setFilter(new FilterList(new FirstKeyOnlyFilter(), new InclusiveStopFilter(new byte[0]))); in testFilterAllRecords()
|