| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/coprocessor/ |
| H A D | AggregationClient.java | 156 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in max()
185 || (Bytes.equals(scan.getStartRow(), scan.getStopRow()) && !Bytes in validateParameters()
187 || ((Bytes.compareTo(scan.getStartRow(), scan.getStopRow()) > 0) && in validateParameters()
188 !Bytes.equals(scan.getStopRow(), HConstants.EMPTY_END_ROW))) { in validateParameters()
244 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in min()
320 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in rowCount()
385 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in sum()
452 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in getAvgArgs()
556 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in getStdArgs()
672 table.coprocessorService(AggregateService.class, scan.getStartRow(), scan.getStopRow(), in getMedianArgs()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ |
| H A D | ReversedClientScanner.java | 148 if (this.scan.getStopRow().length > 0) { in checkScanStopRow()
150 byte[] stopRow = scan.getStopRow(); in checkScanStopRow()
|
| H A D | Scan.java | 211 stopRow = scan.getStopRow(); in Scan()
592 public byte [] getStopRow() { in getStopRow() method in Scan
|
| H A D | ClientScanner.java | 227 if (this.scan.getStopRow().length > 0) { in checkScanStopRow()
229 byte [] stopRow = scan.getStopRow(); in checkScanStopRow()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ |
| H A D | TableSnapshotScanner.java | 132 if (CellUtil.overlappingKeys(scan.getStartRow(), scan.getStopRow(), in init()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ |
| H A D | TestSerialization.java | 358 assertTrue(Bytes.equals(scan.getStopRow(), desScan.getStopRow())); in testScan()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | StoreFile.java | 1384 && Bytes.equals(scan.getStopRow(), HConstants.EMPTY_END_ROW)) { in passesKeyRangeFilter()
1388 .createFirstOnRow(scan.getStopRow()) : KeyValueUtil.createFirstOnRow(scan in passesKeyRangeFilter()
1392 .getStopRow()); in passesKeyRangeFilter()
1395 .equals(scan.isReversed() ? scan.getStartRow() : scan.getStopRow(), in passesKeyRangeFilter()
|
| H A D | ScanQueryMatcher.java | 172 this.stopRow = scan.getStopRow(); in ScanQueryMatcher()
|
| H A D | StoreScanner.java | 313 isCompaction, matcher, scan.getStartRow(), scan.getStopRow(), this.readPt)); in getScannersNoCompaction()
|
| H A D | HRegion.java | 5483 if (Bytes.equals(scan.getStopRow(), HConstants.EMPTY_END_ROW) && !scan.isGetScan()) { in RegionScannerImpl()
5486 this.stopRow = scan.getStopRow(); in RegionScannerImpl()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/ |
| H A D | MultiRowRangeFilter.java | 180 rangeProto.getStopRow().toByteArray() : null, rangeProto.getStopRowInclusive()); in parseFrom()
455 public byte[] getStopRow() { in getStopRow() method in MultiRowRangeFilter.RowRange
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/ |
| H A D | TestMultiTableSnapshotInputFormatImpl.java | 119 this.stopRow = Bytes.toStringBinary(scan.getStopRow()); in ScanWithEquals()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/ |
| H A D | TestBulkDeleteProtocol.java | 148 .getStartRow(), scan.getStopRow(), callable); in invokeBulkDeleteProtocol()
398 .getStartRow(), scan.getStopRow(), callable); in testBulkDeleteWithNumberOfVersions()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/ |
| H A D | MultiTableInputFormatBase.java | 203 byte[] stopRow = scan.getStopRow();
|
| H A D | TableSnapshotInputFormatImpl.java | 317 if (CellUtil.overlappingKeys(scan.getStartRow(), scan.getStopRow(), hri.getStartKey(), in getSplits()
|
| H A D | TableInputFormatBase.java | 294 byte[] stopRow = scan.getStopRow();
|
| /dports/databases/hbase/hbase-1.2.1/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/model/ |
| H A D | ScannerModel.java | 305 range.getStopRow(), range.isStopRowInclusive())); in FilterModel()
512 model.setEndRow(scan.getStopRow()); in fromScan()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/ |
| H A D | TestMultiRowRangeFilter.java | 230 Assert.assertTrue(Bytes.equals(expected.get(i).getStopRow(), actual.get(i).getStopRow())); in assertRangesEqual()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ |
| H A D | ThriftUtilities.java | 388 out.setStopRow(in.getStopRow()); in scanFromThrift()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/ |
| H A D | TScan.java | 273 public byte[] getStopRow() { in getStopRow() method in TScan
578 return getStopRow(); in getFieldValue()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/ |
| H A D | TScan.java | 301 public byte[] getStopRow() { in getStopRow() method in TScan
682 return getStopRow(); in getFieldValue()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/ |
| H A D | ProtobufUtil.java | 907 byte[] stopRow = scan.getStopRow(); in toScan()
962 stopRow = proto.getStopRow().toByteArray(); in toScan()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ |
| H A D | ThriftServerRunner.java | 1453 scan.setStopRow(tScan.getStopRow()); in scannerOpenWithScan()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ |
| H A D | FilterProtos.java | 15915 com.google.protobuf.ByteString getStopRow(); in getStopRow() method
16082 public com.google.protobuf.ByteString getStopRow() { in getStopRow() method in FilterProtos.RowRange
16192 result = result && getStopRow() in equals()
16193 .equals(other.getStopRow()); in equals()
16223 hash = (53 * hash) + getStopRow().hashCode(); in hashCode()
16413 setStopRow(other.getStopRow()); in mergeFrom()
16525 public com.google.protobuf.ByteString getStopRow() { in getStopRow() method in FilterProtos.RowRange.Builder
16545 stopRow_ = getDefaultInstance().getStopRow(); in clearStopRow()
|
| H A D | ClientProtos.java | 14050 com.google.protobuf.ByteString getStopRow(); in getStopRow() method
14570 public com.google.protobuf.ByteString getStopRow() { in getStopRow() method in ClientProtos.Scan
15087 result = result && getStopRow() in equals()
15088 .equals(other.getStopRow()); in equals()
15189 hash = (53 * hash) + getStopRow().hashCode(); in hashCode()
15633 setStopRow(other.getStopRow()); in mergeFrom()
16281 public com.google.protobuf.ByteString getStopRow() { in getStopRow() method in ClientProtos.Scan.Builder
16301 stopRow_ = getDefaultInstance().getStopRow(); in clearStopRow()
|