/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()
|