You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2015/04/08 18:32:41 UTC
[1/3] hbase git commit: Revert "HBASE-11544 [Ergonomics]
hbase.client.scanner.caching is dogged and will try to return batch even if
it means OOME" References the wrong JIRA above so revert;
also an addendum is on the way.
Repository: hbase
Updated Branches:
refs/heads/master 26ba621e4 -> 8cd3001f8
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java
index 6abe076..6a5e844 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java
@@ -128,10 +128,11 @@ import org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor.Stor
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor;
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor;
import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region.RowLock;
import org.apache.hadoop.hbase.regionserver.TestStore.FaultyFileSystem;
-import org.apache.hadoop.hbase.regionserver.handler.FinishRegionRecoveringHandler;
import org.apache.hadoop.hbase.regionserver.wal.HLogKey;
+import org.apache.hadoop.hbase.regionserver.handler.FinishRegionRecoveringHandler;
import org.apache.hadoop.hbase.regionserver.wal.MetricsWAL;
import org.apache.hadoop.hbase.regionserver.wal.MetricsWALSource;
import org.apache.hadoop.hbase.regionserver.wal.WALActionsListener;
@@ -1264,7 +1265,7 @@ public class TestHRegion {
boolean more = false;
List<Cell> results = new ArrayList<Cell>();
do {
- more = scanner.next(results);
+ more = NextState.hasMoreValues(scanner.next(results));
if (results != null && !results.isEmpty())
count++;
else
@@ -1283,7 +1284,7 @@ public class TestHRegion {
List<Cell> results = new ArrayList<Cell>();
boolean more = false;
do {
- more = resultScanner.next(results);
+ more = NextState.hasMoreValues(resultScanner.next(results));
if (results != null && !results.isEmpty())
numberOfResults++;
else
@@ -2273,7 +2274,7 @@ public class TestHRegion {
InternalScanner s = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(false, s.next(results));
+ assertEquals(false, NextState.hasMoreValues(s.next(results)));
assertEquals(1, results.size());
Cell kv = results.get(0);
@@ -2765,7 +2766,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -2828,7 +2829,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -2910,7 +2911,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -2971,7 +2972,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -3032,7 +3033,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -3085,7 +3086,7 @@ public class TestHRegion {
InternalScanner s = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(false, s.next(results));
+ assertEquals(false, NextState.hasMoreValues(s.next(results)));
assertEquals(0, results.size());
} finally {
HBaseTestingUtility.closeRegionAndWAL(this.region);
@@ -3159,7 +3160,7 @@ public class TestHRegion {
List<Cell> actual = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(actual);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(actual));
assertEquals(false, hasNext);
// Verify result
@@ -3222,18 +3223,18 @@ public class TestHRegion {
InternalScanner s = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- assertTrue(s.next(results));
+ assertTrue(NextState.hasMoreValues(s.next(results)));
assertEquals(results.size(), 1);
results.clear();
- assertTrue(s.next(results));
+ assertTrue(NextState.hasMoreValues(s.next(results)));
assertEquals(results.size(), 3);
assertTrue("orderCheck", CellUtil.matchingFamily(results.get(0), cf_alpha));
assertTrue("orderCheck", CellUtil.matchingFamily(results.get(1), cf_essential));
assertTrue("orderCheck", CellUtil.matchingFamily(results.get(2), cf_joined));
results.clear();
- assertFalse(s.next(results));
+ assertFalse(NextState.hasMoreValues(s.next(results)));
assertEquals(results.size(), 0);
} finally {
HBaseTestingUtility.closeRegionAndWAL(this.region);
@@ -3316,9 +3317,8 @@ public class TestHRegion {
List<Cell> results = new ArrayList<Cell>();
int index = 0;
- ScannerContext scannerContext = ScannerContext.newBuilder().setBatchLimit(3).build();
while (true) {
- boolean more = s.next(results, scannerContext);
+ boolean more = NextState.hasMoreValues(s.next(results, 3));
if ((index >> 1) < 5) {
if (index % 2 == 0)
assertEquals(results.size(), 3);
@@ -3592,7 +3592,7 @@ public class TestHRegion {
if (toggle) {
flushThread.flush();
}
- while (scanner.next(res))
+ while (NextState.hasMoreValues(scanner.next(res)))
;
if (!toggle) {
flushThread.flush();
@@ -3717,7 +3717,7 @@ public class TestHRegion {
boolean previousEmpty = res.isEmpty();
res.clear();
InternalScanner scanner = region.getScanner(scan);
- while (scanner.next(res))
+ while (NextState.hasMoreValues(scanner.next(res)))
;
if (!res.isEmpty() || !previousEmpty || i > compactInterval) {
assertEquals("i=" + i, expectedCount, res.size());
@@ -3999,7 +3999,7 @@ public class TestHRegion {
InternalScanner scanner = region.getScanner(idxScan);
List<Cell> res = new ArrayList<Cell>();
- while (scanner.next(res))
+ while (NextState.hasMoreValues(scanner.next(res)))
;
assertEquals(1L, res.size());
} finally {
@@ -4895,7 +4895,7 @@ public class TestHRegion {
try {
List<Cell> curVals = new ArrayList<Cell>();
boolean first = true;
- OUTER_LOOP: while (s.next(curVals)) {
+ OUTER_LOOP: while (NextState.hasMoreValues(s.next(curVals))) {
for (Cell kv : curVals) {
byte[] val = CellUtil.cloneValue(kv);
byte[] curval = val;
@@ -5091,17 +5091,17 @@ public class TestHRegion {
scan.setReversed(true);
InternalScanner scanner = region.getScanner(scan);
List<Cell> currRow = new ArrayList<Cell>();
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(2, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowC));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowA));
assertFalse(hasNext);
@@ -5148,17 +5148,17 @@ public class TestHRegion {
scan.setReversed(true);
scan.setMaxVersions(5);
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(2, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowC));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowA));
assertFalse(hasNext);
@@ -5202,17 +5202,17 @@ public class TestHRegion {
List<Cell> currRow = new ArrayList<Cell>();
scan.setReversed(true);
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowC));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowA));
assertFalse(hasNext);
@@ -5270,17 +5270,17 @@ public class TestHRegion {
scan.setReversed(true);
List<Cell> currRow = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowD));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowC));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
assertFalse(hasNext);
@@ -5291,7 +5291,7 @@ public class TestHRegion {
scan.setReversed(true);
currRow.clear();
scanner = region.getScanner(scan);
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowD));
scanner.close();
@@ -5350,17 +5350,17 @@ public class TestHRegion {
scan.setReversed(true);
List<Cell> currRow = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowD));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowC));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowB));
assertFalse(hasNext);
@@ -5371,7 +5371,7 @@ public class TestHRegion {
scan.setReversed(true);
currRow.clear();
scanner = region.getScanner(scan);
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), rowD));
scanner.close();
@@ -5495,42 +5495,42 @@ public class TestHRegion {
// 1. scan out "row4" (5 kvs), "row5" can't be scanned out since not
// included in scan range
// "row4" takes 2 next() calls since batch=3
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(3, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row4));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(2, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row4));
assertTrue(hasNext);
// 2. scan out "row3" (2 kv)
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(2, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row3));
assertTrue(hasNext);
// 3. scan out "row2" (4 kvs)
// "row2" takes 2 next() calls since batch=3
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(3, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row2));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row2));
assertTrue(hasNext);
// 4. scan out "row1" (2 kv)
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(2, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row1));
assertTrue(hasNext);
// 5. scan out "row0" (1 kv)
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row0));
assertFalse(hasNext);
@@ -5591,22 +5591,22 @@ public class TestHRegion {
scan.setBatch(10);
InternalScanner scanner = region.getScanner(scan);
List<Cell> currRow = new ArrayList<Cell>();
- boolean hasNext = scanner.next(currRow);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row4));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row3));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row2));
assertTrue(hasNext);
currRow.clear();
- hasNext = scanner.next(currRow);
+ hasNext = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(1, currRow.size());
assertTrue(Bytes.equals(currRow.get(0).getRow(), row1));
assertFalse(hasNext);
@@ -5659,7 +5659,7 @@ public class TestHRegion {
boolean more = false;
int verify = startRow + 2 * numRows - 1;
do {
- more = scanner.next(currRow);
+ more = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(Bytes.toString(currRow.get(0).getRow()), verify + "");
verify--;
currRow.clear();
@@ -5672,7 +5672,7 @@ public class TestHRegion {
scanner = regions[1].getScanner(scan);
verify = startRow + 2 * numRows - 1;
do {
- more = scanner.next(currRow);
+ more = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(Bytes.toString(currRow.get(0).getRow()), verify + "");
verify--;
currRow.clear();
@@ -5685,7 +5685,7 @@ public class TestHRegion {
scanner = regions[0].getScanner(scan);
verify = startRow + numRows - 1;
do {
- more = scanner.next(currRow);
+ more = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(Bytes.toString(currRow.get(0).getRow()), verify + "");
verify--;
currRow.clear();
@@ -5698,7 +5698,7 @@ public class TestHRegion {
scanner = regions[0].getScanner(scan);
verify = startRow + numRows - 1;
do {
- more = scanner.next(currRow);
+ more = NextState.hasMoreValues(scanner.next(currRow));
assertEquals(Bytes.toString(currRow.get(0).getRow()), verify + "");
verify--;
currRow.clear();
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestKeepDeletes.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestKeepDeletes.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestKeepDeletes.java
index 9286e0d..c480cd8 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestKeepDeletes.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestKeepDeletes.java
@@ -38,6 +38,7 @@ import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -263,8 +264,7 @@ public class TestKeepDeletes {
s.setTimeRange(0L, ts+1);
InternalScanner scanner = region.getScanner(s);
List<Cell> kvs = new ArrayList<Cell>();
- while (scanner.next(kvs))
- ;
+ while (NextState.hasMoreValues(scanner.next(kvs)));
assertTrue(kvs.isEmpty());
// flushing and minor compaction keep delete markers
@@ -946,7 +946,7 @@ public class TestKeepDeletes {
int res = 0;
boolean hasMore;
do {
- hasMore = scan.next(kvs);
+ hasMore = NextState.hasMoreValues(scan.next(kvs));
for (Cell kv : kvs) {
if(CellUtil.isDelete(kv)) res++;
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMajorCompaction.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMajorCompaction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMajorCompaction.java
index cc16804..12ab2ad 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMajorCompaction.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMajorCompaction.java
@@ -52,6 +52,7 @@ import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
import org.apache.hadoop.hbase.io.hfile.HFileDataBlockEncoder;
import org.apache.hadoop.hbase.io.hfile.HFileDataBlockEncoderImpl;
import org.apache.hadoop.hbase.io.hfile.HFileScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionProgress;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest;
import org.apache.hadoop.hbase.regionserver.compactions.RatioBasedCompactionPolicy;
@@ -131,7 +132,7 @@ public class TestMajorCompaction {
InternalScanner s = r.getScanner(new Scan());
do {
List<Cell> results = new ArrayList<Cell>();
- boolean result = s.next(results);
+ boolean result = NextState.hasMoreValues(s.next(results));
r.delete(new Delete(CellUtil.cloneRow(results.get(0))));
if (!result) break;
} while(true);
@@ -144,7 +145,7 @@ public class TestMajorCompaction {
int counter = 0;
do {
List<Cell> results = new ArrayList<Cell>();
- boolean result = s.next(results);
+ boolean result = NextState.hasMoreValues(s.next(results));
if (!result) break;
counter++;
} while(true);
@@ -455,7 +456,7 @@ public class TestMajorCompaction {
InternalScanner s = r.getScanner(scan);
do {
List<Cell> results = new ArrayList<Cell>();
- boolean result = s.next(results);
+ boolean result = NextState.hasMoreValues(s.next(results));
assertTrue(!results.isEmpty());
r.delete(new Delete(results.get(0).getRow()));
if (!result) break;
@@ -471,7 +472,7 @@ public class TestMajorCompaction {
int counter = 0;
do {
List<Cell> results = new ArrayList<Cell>();
- boolean result = s.next(results);
+ boolean result = NextState.hasMoreValues(s.next(results));
if (!result) break;
counter++;
} while (true);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java
index dfdc4e4..28d3ab9 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java
@@ -49,6 +49,7 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.compress.Compression;
import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -249,7 +250,7 @@ public class TestMultiColumnScanner {
String queryInfo = "columns queried: " + qualSet + " (columnBitMask="
+ columnBitMask + "), maxVersions=" + maxVersions;
- while (scanner.next(results) || results.size() > 0) {
+ while (NextState.hasMoreValues(scanner.next(results)) || results.size() > 0) {
for (Cell kv : results) {
while (kvPos < kvs.size()
&& !matchesQuery(kvs.get(kvPos), qualSet, maxVersions,
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransaction.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransaction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransaction.java
index b2115b3..313a6ba 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransaction.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransaction.java
@@ -44,6 +44,7 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -426,7 +427,7 @@ public class TestRegionMergeTransaction {
List<Cell> kvs = new ArrayList<Cell>();
boolean hasNext = true;
while (hasNext) {
- hasNext = scanner.next(kvs);
+ hasNext = NextState.hasMoreValues(scanner.next(kvs));
if (!kvs.isEmpty())
rowcount++;
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestReversibleScanners.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestReversibleScanners.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestReversibleScanners.java
index 8052d9c..92915e6 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestReversibleScanners.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestReversibleScanners.java
@@ -55,6 +55,7 @@ import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
import org.apache.hadoop.hbase.io.hfile.CacheConfig;
import org.apache.hadoop.hbase.io.hfile.HFileContext;
import org.apache.hadoop.hbase.io.hfile.HFileContextBuilder;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -433,7 +434,7 @@ public class TestReversibleScanners {
int rowCount = 0;
int kvCount = 0;
try {
- while (scanner.next(kvList)) {
+ while (NextState.hasMoreValues(scanner.next(kvList))) {
if (kvList.isEmpty()) continue;
rowCount++;
kvCount += kvList.size();
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java
index eada3fb..ccae4bc 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java
@@ -47,6 +47,7 @@ import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.compress.Compression;
import org.apache.hadoop.hbase.io.hfile.HFilePrettyPrinter;
import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -164,7 +165,7 @@ public class TestScanWithBloomError {
{ // Limit the scope of results.
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results) || results.size() > 0) {
+ while (NextState.hasMoreValues(scanner.next(results)) || results.size() > 0) {
allResults.addAll(results);
results.clear();
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanner.java
index 84cb355..ee72ce4 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanner.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanner.java
@@ -54,6 +54,7 @@ import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.filter.InclusiveStopFilter;
import org.apache.hadoop.hbase.filter.PrefixFilter;
import org.apache.hadoop.hbase.filter.WhileMatchFilter;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -136,7 +137,7 @@ public class TestScanner {
InternalScanner s = r.getScanner(scan);
int count = 0;
- while (s.next(results)) {
+ while (NextState.hasMoreValues(s.next(results))) {
count++;
}
s.close();
@@ -149,7 +150,7 @@ public class TestScanner {
count = 0;
Cell kv = null;
results = new ArrayList<Cell>();
- for (boolean first = true; s.next(results);) {
+ for (boolean first = true; NextState.hasMoreValues(s.next(results));) {
kv = results.get(0);
if (first) {
assertTrue(CellUtil.matchingRow(kv, startrow));
@@ -172,7 +173,7 @@ public class TestScanner {
InternalScanner s = r.getScanner(scan);
boolean hasMore = true;
while (hasMore) {
- hasMore = s.next(results);
+ hasMore = NextState.hasMoreValues(s.next(results));
for (Cell kv : results) {
assertEquals((byte)'a', CellUtil.cloneRow(kv)[0]);
assertEquals((byte)'b', CellUtil.cloneRow(kv)[1]);
@@ -188,7 +189,7 @@ public class TestScanner {
InternalScanner s = r.getScanner(scan);
boolean hasMore = true;
while (hasMore) {
- hasMore = s.next(results);
+ hasMore = NextState.hasMoreValues(s.next(results));
for (Cell kv : results) {
assertTrue(Bytes.compareTo(CellUtil.cloneRow(kv), stopRow) <= 0);
}
@@ -388,7 +389,7 @@ public class TestScanner {
scan.addColumn(COLS[0], EXPLICIT_COLS[ii]);
}
scanner = r.getScanner(scan);
- while (scanner.next(results)) {
+ while (NextState.hasMoreValues(scanner.next(results))) {
assertTrue(hasColumn(results, HConstants.CATALOG_FAMILY,
HConstants.REGIONINFO_QUALIFIER));
byte [] val = CellUtil.cloneValue(getColumn(results, HConstants.CATALOG_FAMILY,
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java
index 1e09c40..dfced3b 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java
@@ -44,6 +44,7 @@ import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.compress.Compression;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -224,7 +225,7 @@ public class TestSeekOptimizations {
// result, not to the one already returned in results.
boolean hasNext;
do {
- hasNext = scanner.next(results);
+ hasNext = NextState.hasMoreValues(scanner.next(results));
actualKVs.addAll(results);
results.clear();
} while (hasNext);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransaction.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransaction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransaction.java
index 4f371bd..da4f811 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransaction.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSplitTransaction.java
@@ -50,6 +50,7 @@ import org.apache.hadoop.hbase.coprocessor.ObserverContext;
import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
import org.apache.hadoop.hbase.io.hfile.CacheConfig;
import org.apache.hadoop.hbase.io.hfile.LruBlockCache;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -360,7 +361,7 @@ public class TestSplitTransaction {
List<Cell> kvs = new ArrayList<Cell>();
boolean hasNext = true;
while (hasNext) {
- hasNext = scanner.next(kvs);
+ hasNext = NextState.hasMoreValues(scanner.next(kvs));
if (!kvs.isEmpty()) rowcount++;
}
} finally {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreScanner.java
index ee39212..c723c2e 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreScanner.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreScanner.java
@@ -36,6 +36,7 @@ import org.apache.hadoop.hbase.KeepDeletedCells;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.KeyValueTestUtil;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -90,7 +91,7 @@ public class TestStoreScanner extends TestCase {
StoreScanner scan = new StoreScanner(scanSpec, scanInfo, scanType,
getCols("a"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(5, results.size());
assertEquals(kvs[kvs.length - 1], results.get(0));
// Scan limited TimeRange
@@ -100,7 +101,7 @@ public class TestStoreScanner extends TestCase {
scan = new StoreScanner(scanSpec, scanInfo, scanType, getCols("a"),
scanners);
results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(2, results.size());
// Another range.
scanSpec = new Scan(Bytes.toBytes(r1));
@@ -109,7 +110,7 @@ public class TestStoreScanner extends TestCase {
scan = new StoreScanner(scanSpec, scanInfo, scanType, getCols("a"),
scanners);
results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
// See how TimeRange and Versions interact.
// Another range.
@@ -119,7 +120,7 @@ public class TestStoreScanner extends TestCase {
scan = new StoreScanner(scanSpec, scanInfo, scanType, getCols("a"),
scanners);
results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(3, results.size());
}
@@ -140,7 +141,7 @@ public class TestStoreScanner extends TestCase {
getCols("a"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[0], results.get(0));
}
@@ -195,7 +196,7 @@ public class TestStoreScanner extends TestCase {
getCols("a"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertFalse(scan.next(results));
+ assertFalse(NextState.hasMoreValues(scan.next(results)));
assertEquals(0, results.size());
}
@@ -215,14 +216,14 @@ public class TestStoreScanner extends TestCase {
getCols("a"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(0, results.size());
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[2], results.get(0));
- assertEquals(false, scan.next(results));
+ assertEquals(false, NextState.hasMoreValues(scan.next(results)));
}
public void testDeleteVersionMaskingMultiplePuts() throws IOException {
@@ -244,7 +245,7 @@ public class TestStoreScanner extends TestCase {
// the two put at ts=now will be masked by the 1 delete, and
// since the scan default returns 1 version we'll return the newest
// key, which is kvs[2], now-100.
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs2[1], results.get(0));
}
@@ -266,7 +267,7 @@ public class TestStoreScanner extends TestCase {
StoreScanner scan = new StoreScanner(scanSpec, scanInfo, scanType,
getCols("a"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(2, results.size());
assertEquals(kvs2[1], results.get(0));
assertEquals(kvs2[0], results.get(1));
@@ -282,7 +283,7 @@ public class TestStoreScanner extends TestCase {
StoreScanner scan = new StoreScanner(new Scan(Bytes.toBytes("R1")),
scanInfo, scanType, null, scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(2, results.size());
assertEquals(kvs[0], results.get(0));
assertEquals(kvs[1], results.get(1));
@@ -311,7 +312,7 @@ public class TestStoreScanner extends TestCase {
StoreScanner scan = new StoreScanner(new Scan().setMaxVersions(2),
scanInfo, scanType, null, scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(5, results.size());
assertEquals(kvs[0], results.get(0));
assertEquals(kvs[2], results.get(1));
@@ -340,13 +341,13 @@ public class TestStoreScanner extends TestCase {
new Scan().setMaxVersions(Integer.MAX_VALUE), scanInfo, scanType, null,
scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(0, results.size());
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[kvs.length-1], results.get(0));
- assertEquals(false, scan.next(results));
+ assertEquals(false, NextState.hasMoreValues(scan.next(results)));
}
public void testDeleteColumn() throws IOException {
@@ -360,7 +361,7 @@ public class TestStoreScanner extends TestCase {
StoreScanner scan = new StoreScanner(new Scan(), scanInfo, scanType, null,
scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[3], results.get(0));
}
@@ -384,18 +385,18 @@ public class TestStoreScanner extends TestCase {
getCols("a", "d"), scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(2, results.size());
assertEquals(kvs[0], results.get(0));
assertEquals(kvs[3], results.get(1));
results.clear();
- assertEquals(true, scan.next(results));
+ assertEquals(true, NextState.hasMoreValues(scan.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[kvs.length-1], results.get(0));
results.clear();
- assertEquals(false, scan.next(results));
+ assertEquals(false, NextState.hasMoreValues(scan.next(results)));
}
/*
@@ -425,20 +426,20 @@ public class TestStoreScanner extends TestCase {
null, scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scanner.next(results));
+ assertEquals(true, NextState.hasMoreValues(scanner.next(results)));
assertEquals(2, results.size());
assertEquals(kvs[1], results.get(0));
assertEquals(kvs[2], results.get(1));
results.clear();
- assertEquals(true, scanner.next(results));
+ assertEquals(true, NextState.hasMoreValues(scanner.next(results)));
assertEquals(3, results.size());
assertEquals(kvs[4], results.get(0));
assertEquals(kvs[5], results.get(1));
assertEquals(kvs[6], results.get(2));
results.clear();
- assertEquals(false, scanner.next(results));
+ assertEquals(false, NextState.hasMoreValues(scanner.next(results)));
}
public void testScannerReseekDoesntNPE() throws Exception {
@@ -495,12 +496,12 @@ public class TestStoreScanner extends TestCase {
new StoreScanner(scan, scanInfo, scanType, null, scanners);
List<Cell> results = new ArrayList<Cell>();
- assertEquals(true, scanner.next(results));
+ assertEquals(true, NextState.hasMoreValues(scanner.next(results)));
assertEquals(1, results.size());
assertEquals(kvs[1], results.get(0));
results.clear();
- assertEquals(false, scanner.next(results));
+ assertEquals(false, NextState.hasMoreValues(scanner.next(results)));
}
public void testDeleteMarkerLongevity() throws Exception {
@@ -560,7 +561,7 @@ public class TestStoreScanner extends TestCase {
HConstants.OLDEST_TIMESTAMP);
List<Cell> results = new ArrayList<Cell>();
results = new ArrayList<Cell>();
- assertEquals(true, scanner.next(results));
+ assertEquals(true, NextState.hasMoreValues(scanner.next(results)));
assertEquals(kvs[0], results.get(0));
assertEquals(kvs[2], results.get(1));
assertEquals(kvs[3], results.get(2));
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStripeCompactor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStripeCompactor.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStripeCompactor.java
index b743550..06bbd54 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStripeCompactor.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStripeCompactor.java
@@ -237,14 +237,22 @@ public class TestStripeCompactor {
}
@Override
- public boolean next(List<Cell> results) throws IOException {
- if (kvs.isEmpty()) return false;
+ public NextState next(List<Cell> results) throws IOException {
+ if (kvs.isEmpty()) return NextState.makeState(NextState.State.NO_MORE_VALUES);
results.add(kvs.remove(0));
- return !kvs.isEmpty();
+ if (!kvs.isEmpty()) {
+ return NextState.makeState(NextState.State.MORE_VALUES);
+ } else {
+ return NextState.makeState(NextState.State.NO_MORE_VALUES);
+ }
+ }
+ @Override
+ public NextState next(List<Cell> result, int limit) throws IOException {
+ return next(result);
}
@Override
- public boolean next(List<Cell> result, ScannerContext scannerContext)
+ public NextState next(List<Cell> result, int limit, long remainingResultSize)
throws IOException {
return next(result);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWideScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWideScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWideScanner.java
index fb4561b..303ee36 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWideScanner.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestWideScanner.java
@@ -37,6 +37,7 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -105,7 +106,7 @@ public class TestWideScanner extends HBaseTestCase {
int i = 0;
boolean more;
do {
- more = s.next(results);
+ more = NextState.hasMoreValues(s.next(results));
i++;
LOG.info("iteration #" + i + ", results.size=" + results.size());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestStripeCompactionPolicy.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestStripeCompactionPolicy.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestStripeCompactionPolicy.java
index 81f8115..3294f6d 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestStripeCompactionPolicy.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestStripeCompactionPolicy.java
@@ -54,7 +54,6 @@ import org.apache.hadoop.hbase.io.hfile.HFile;
import org.apache.hadoop.hbase.regionserver.BloomType;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
import org.apache.hadoop.hbase.regionserver.ScanType;
-import org.apache.hadoop.hbase.regionserver.ScannerContext;
import org.apache.hadoop.hbase.regionserver.Store;
import org.apache.hadoop.hbase.regionserver.StoreConfigInformation;
import org.apache.hadoop.hbase.regionserver.StoreFile;
@@ -775,15 +774,24 @@ public class TestStripeCompactionPolicy {
}
@Override
- public boolean next(List<Cell> results) throws IOException {
- if (kvs.isEmpty()) return false;
+ public NextState next(List<Cell> results) throws IOException {
+ if (kvs.isEmpty()) return NextState.makeState(NextState.State.NO_MORE_VALUES);
results.add(kvs.remove(0));
- return !kvs.isEmpty();
+ if (!kvs.isEmpty()) {
+ return NextState.makeState(NextState.State.MORE_VALUES);
+ } else {
+ return NextState.makeState(NextState.State.NO_MORE_VALUES);
+ }
+ }
+
+ @Override
+ public NextState next(List<Cell> result, int limit) throws IOException {
+ return next(result);
}
@Override
- public boolean next(List<Cell> result, ScannerContext scannerContext)
+ public NextState next(List<Cell> result, int limit, long remainingResultSize)
throws IOException {
return next(result);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java
index 5310a2e..afdcdc7 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java
@@ -71,6 +71,7 @@ import org.apache.hadoop.hbase.regionserver.FlushRequestListener;
import org.apache.hadoop.hbase.regionserver.FlushRequester;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.HRegionServer;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.MemStoreSnapshot;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
@@ -750,7 +751,7 @@ public class TestWALReplay {
int scannedCount = 0;
List<Cell> results = new ArrayList<Cell>();
while (true) {
- boolean existMore = scanner.next(results);
+ boolean existMore = NextState.hasMoreValues(scanner.next(results));
if (!results.isEmpty())
scannedCount++;
if (!existMore)
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestMergeTool.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestMergeTool.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestMergeTool.java
index 056eeb2..c071a33 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestMergeTool.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestMergeTool.java
@@ -40,6 +40,7 @@ import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.testclassification.MiscTests;
import org.apache.hadoop.hbase.wal.WAL;
@@ -231,7 +232,7 @@ public class TestMergeTool extends HBaseTestCase {
List<Cell> testRes = null;
while (true) {
testRes = new ArrayList<Cell>();
- boolean hasNext = scanner.next(testRes);
+ boolean hasNext = NextState.hasMoreValues(scanner.next(testRes));
if (!hasNext) {
break;
}
[3/3] hbase git commit: Revert "HBASE-11544 [Ergonomics]
hbase.client.scanner.caching is dogged and will try to return batch even if
it means OOME" References the wrong JIRA above so revert;
also an addendum is on the way.
Posted by st...@apache.org.
Revert "HBASE-11544 [Ergonomics] hbase.client.scanner.caching is dogged and will try to return batch even if it means OOME"
References the wrong JIRA above so revert; also an addendum is on the
way.
This reverts commit 26ba621e47e886fb3b1336f2201b8efbda86ff91.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8cd3001f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8cd3001f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8cd3001f
Branch: refs/heads/master
Commit: 8cd3001f817915df20a4d209c450ac9b69b915d7
Parents: 26ba621
Author: stack <st...@apache.org>
Authored: Wed Apr 8 09:32:09 2015 -0700
Committer: stack <st...@apache.org>
Committed: Wed Apr 8 09:32:09 2015 -0700
----------------------------------------------------------------------
.../apache/hadoop/hbase/HTableDescriptor.java | 22 +-
.../hadoop/hbase/client/ClientScanner.java | 3 -
.../client/ScannerCallableWithReplicas.java | 34 +-
.../java/org/apache/hadoop/hbase/CellUtil.java | 1 -
.../org/apache/hadoop/hbase/HConstants.java | 19 +-
.../coprocessor/example/BulkDeleteEndpoint.java | 3 +-
.../coprocessor/example/RowCountEndpoint.java | 5 +-
.../hbase/client/ClientSideRegionScanner.java | 8 +-
.../coprocessor/AggregateImplementation.java | 15 +-
.../hadoop/hbase/regionserver/HRegion.java | 271 +++++-----
.../hbase/regionserver/InternalScanner.java | 209 +++++++-
.../hadoop/hbase/regionserver/KeyValueHeap.java | 44 +-
.../regionserver/NoLimitScannerContext.java | 94 ----
.../hbase/regionserver/RSRpcServices.java | 66 ++-
.../hbase/regionserver/RegionScanner.java | 50 +-
.../hbase/regionserver/ScannerContext.java | 527 -------------------
.../hadoop/hbase/regionserver/StoreFlusher.java | 7 +-
.../hadoop/hbase/regionserver/StoreScanner.java | 78 +--
.../regionserver/compactions/Compactor.java | 7 +-
.../security/access/AccessControlLists.java | 3 +-
.../hbase/security/access/AccessController.java | 6 +-
.../org/apache/hadoop/hbase/HBaseTestCase.java | 3 +-
.../hbase/TestPartialResultsFromClientSide.java | 8 +-
.../hbase/client/TestIntraRowPagination.java | 3 +-
.../hadoop/hbase/client/TestReplicasClient.java | 90 +---
.../coprocessor/ColumnAggregationEndpoint.java | 3 +-
.../ColumnAggregationEndpointNullResponse.java | 3 +-
.../ColumnAggregationEndpointWithErrors.java | 3 +-
.../coprocessor/TestCoprocessorInterface.java | 23 +-
.../TestRegionObserverInterface.java | 19 +-
.../hbase/filter/TestColumnPrefixFilter.java | 7 +-
.../hbase/filter/TestDependentColumnFilter.java | 3 +-
.../apache/hadoop/hbase/filter/TestFilter.java | 29 +-
.../filter/TestInvocationRecordFilter.java | 5 +-
.../filter/TestMultipleColumnPrefixFilter.java | 9 +-
.../hbase/io/encoding/TestPrefixTree.java | 11 +-
.../TestScannerSelectionUsingKeyRange.java | 5 +-
.../io/hfile/TestScannerSelectionUsingTTL.java | 3 +-
.../hbase/regionserver/TestAtomicOperation.java | 9 +-
.../hbase/regionserver/TestBlocksScanned.java | 8 +-
.../hbase/regionserver/TestColumnSeeking.java | 5 +-
.../hbase/regionserver/TestDefaultMemStore.java | 9 +-
.../regionserver/TestGetClosestAtOrBefore.java | 5 +-
.../hadoop/hbase/regionserver/TestHRegion.java | 104 ++--
.../hbase/regionserver/TestKeepDeletes.java | 6 +-
.../hbase/regionserver/TestMajorCompaction.java | 9 +-
.../regionserver/TestMultiColumnScanner.java | 3 +-
.../TestRegionMergeTransaction.java | 3 +-
.../regionserver/TestReversibleScanners.java | 3 +-
.../regionserver/TestScanWithBloomError.java | 3 +-
.../hadoop/hbase/regionserver/TestScanner.java | 11 +-
.../regionserver/TestSeekOptimizations.java | 3 +-
.../regionserver/TestSplitTransaction.java | 3 +-
.../hbase/regionserver/TestStoreScanner.java | 53 +-
.../hbase/regionserver/TestStripeCompactor.java | 16 +-
.../hbase/regionserver/TestWideScanner.java | 3 +-
.../compactions/TestStripeCompactionPolicy.java | 18 +-
.../hbase/regionserver/wal/TestWALReplay.java | 3 +-
.../apache/hadoop/hbase/util/TestMergeTool.java | 3 +-
59 files changed, 787 insertions(+), 1192 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-client/src/main/java/org/apache/hadoop/hbase/HTableDescriptor.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/HTableDescriptor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/HTableDescriptor.java
index 4fae2c7..a0ab484 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/HTableDescriptor.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/HTableDescriptor.java
@@ -159,9 +159,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
*/
@Deprecated
public static final String DEFERRED_LOG_FLUSH = "DEFERRED_LOG_FLUSH";
- /**
- * @deprecated
- */
@Deprecated
private static final Bytes DEFERRED_LOG_FLUSH_KEY =
new Bytes(Bytes.toBytes(DEFERRED_LOG_FLUSH));
@@ -318,7 +315,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
* Construct a table descriptor specifying a byte array table name
* @param name Table name.
* @see <a href="HADOOP-1581">HADOOP-1581 HBASE: Un-openable tablename bug</a>
- * @deprecated
*/
@Deprecated
public HTableDescriptor(final byte[] name) {
@@ -329,7 +325,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
* Construct a table descriptor specifying a String table name
* @param name Table name.
* @see <a href="HADOOP-1581">HADOOP-1581 HBASE: Un-openable tablename bug</a>
- * @deprecated
*/
@Deprecated
public HTableDescriptor(final String name) {
@@ -704,7 +699,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
* Set the name of the table.
*
* @param name name of table
- * @deprecated
*/
@Deprecated
public HTableDescriptor setName(byte[] name) {
@@ -712,9 +706,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
return this;
}
- /**
- * @deprecated
- */
@Deprecated
public HTableDescriptor setName(TableName name) {
this.name = name;
@@ -1349,7 +1340,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
* @param rootdir qualified path of HBase root directory
* @param tableName name of table
* @return {@link Path} for table
- * @deprecated
*/
@Deprecated
public static Path getTableDir(Path rootdir, final byte [] tableName) {
@@ -1363,7 +1353,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
/** Table descriptor for <code>hbase:meta</code> catalog table
* Deprecated, use TableDescriptors#get(TableName.META_TABLE) or
* Admin#getTableDescriptor(TableName.META_TABLE) instead.
- * @deprecated
*/
@Deprecated
public static final HTableDescriptor META_TABLEDESC = new HTableDescriptor(
@@ -1423,18 +1412,12 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
.setCacheDataInL1(true)
});
- /**
- * @deprecated
- */
@Deprecated
public HTableDescriptor setOwner(User owner) {
return setOwnerString(owner != null ? owner.getShortName() : null);
}
- /**
- * used by admin.rb:alter(table_name,*args) to update owner.
- * @deprecated
- */
+ // used by admin.rb:alter(table_name,*args) to update owner.
@Deprecated
public HTableDescriptor setOwnerString(String ownerString) {
if (ownerString != null) {
@@ -1445,9 +1428,6 @@ public class HTableDescriptor implements Comparable<HTableDescriptor> {
return this;
}
- /**
- * @deprecated
- */
@Deprecated
public String getOwnerString() {
if (getValue(OWNER_KEY) != null) {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java
index ccd8c2d..05a780c 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientScanner.java
@@ -401,9 +401,6 @@ public class ClientScanner extends AbstractClientScanner {
// happens for the cases where we see exceptions. Since only openScanner
// would have happened, values would be null
if (values == null && callable.switchedToADifferentReplica()) {
- // Any accumulated partial results are no longer valid since the callable will
- // openScanner with the correct startkey and we must pick up from there
- clearPartialResults();
this.currentRegion = callable.getHRegionInfo();
continue;
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java
index 7ba152b..ca6ab05 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java
@@ -292,7 +292,14 @@ class ScannerCallableWithReplicas implements RetryingCallable<Result[]> {
continue; //this was already scheduled earlier
}
ScannerCallable s = currentScannerCallable.getScannerCallableForReplica(id);
- setStartRowForReplicaCallable(s);
+
+ if (this.lastResult != null) {
+ if(s.getScan().isReversed()){
+ s.getScan().setStartRow(createClosestRowBefore(this.lastResult.getRow()));
+ }else {
+ s.getScan().setStartRow(Bytes.add(this.lastResult.getRow(), new byte[1]));
+ }
+ }
outstandingCallables.add(s);
RetryingRPC retryingOnReplica = new RetryingRPC(s);
cs.submit(retryingOnReplica, scannerTimeout, id);
@@ -300,31 +307,6 @@ class ScannerCallableWithReplicas implements RetryingCallable<Result[]> {
return max - min + 1;
}
- /**
- * Set the start row for the replica callable based on the state of the last result received.
- * @param callable The callable to set the start row on
- */
- private void setStartRowForReplicaCallable(ScannerCallable callable) {
- if (this.lastResult == null || callable == null) return;
-
- if (this.lastResult.isPartial()) {
- // The last result was a partial result which means we have not received all of the cells
- // for this row. Thus, use the last result's row as the start row. If a replica switch
- // occurs, the scanner will ensure that any accumulated partial results are cleared,
- // and the scan can resume from this row.
- callable.getScan().setStartRow(this.lastResult.getRow());
- } else {
- // The last result was not a partial result which means it contained all of the cells for
- // that row (we no longer need any information from it). Set the start row to the next
- // closest row that could be seen.
- if (callable.getScan().isReversed()) {
- callable.getScan().setStartRow(createClosestRowBefore(this.lastResult.getRow()));
- } else {
- callable.getScan().setStartRow(Bytes.add(this.lastResult.getRow(), new byte[1]));
- }
- }
- }
-
@VisibleForTesting
boolean isAnyRPCcancelled() {
return someRPCcancelled;
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java
----------------------------------------------------------------------
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java
index 2060488..bce3957 100644
--- a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java
+++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java
@@ -574,7 +574,6 @@ public final class CellUtil {
* backwards compatible with estimations done by older clients. We need to
* pretend that tags never exist and cells aren't serialized with tag
* length included. See HBASE-13262 and HBASE-13303
- * @deprecated See above comment
*/
@Deprecated
public static long estimatedHeapSizeOfWithoutTags(final Cell cell) {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
----------------------------------------------------------------------
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
index b5a6318..19e251a 100644
--- a/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
+++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/HConstants.java
@@ -391,7 +391,7 @@ public final class HConstants {
/**
* The hbase:meta table's name.
- * @deprecated For 0.94 to 0.96 compatibility. Replaced by define in TableName
+ *
*/
@Deprecated // for compat from 0.94 -> 0.96.
public static final byte[] META_TABLE_NAME = TableName.META_TABLE_NAME.getName();
@@ -579,7 +579,7 @@ public final class HConstants {
* 1, 2, 3, 5, 10, 20, 40, 100, 100, 100.
* With 100ms, a back-off of 200 means 20s
*/
- public static final int [] RETRY_BACKOFF = {1, 2, 3, 5, 10, 20, 40, 100, 100, 100, 100, 200, 200};
+ public static final int RETRY_BACKOFF[] = {1, 2, 3, 5, 10, 20, 40, 100, 100, 100, 100, 200, 200};
public static final String REGION_IMPL = "hbase.hregion.impl";
@@ -780,8 +780,7 @@ public final class HConstants {
/**
* timeout for short operation RPC
*/
- public static final String HBASE_RPC_SHORTOPERATION_TIMEOUT_KEY =
- "hbase.rpc.shortoperation.timeout";
+ public static final String HBASE_RPC_SHORTOPERATION_TIMEOUT_KEY = "hbase.rpc.shortoperation.timeout";
/**
* Default value of {@link #HBASE_RPC_SHORTOPERATION_TIMEOUT_KEY}
@@ -836,8 +835,8 @@ public final class HConstants {
*/
public static final float HBASE_CLUSTER_MINIMUM_MEMORY_THRESHOLD = 0.2f;
- public static final Pattern CP_HTD_ATTR_KEY_PATTERN = Pattern.compile(
- "^coprocessor\\$([0-9]+)$", Pattern.CASE_INSENSITIVE);
+ public static final Pattern CP_HTD_ATTR_KEY_PATTERN = Pattern.compile
+ ("^coprocessor\\$([0-9]+)$", Pattern.CASE_INSENSITIVE);
public static final Pattern CP_HTD_ATTR_VALUE_PATTERN =
Pattern.compile("(^[^\\|]*)\\|([^\\|]+)\\|[\\s]*([\\d]*)[\\s]*(\\|.*)?$");
@@ -890,7 +889,7 @@ public final class HConstants {
* 1 => Abort only all of the handers have died
*/
public static final String REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT =
- "hbase.regionserver.handler.abort.on.error.percent";
+ "hbase.regionserver.handler.abort.on.error.percent";
public static final double DEFAULT_REGION_SERVER_HANDLER_ABORT_ON_ERROR_PERCENT = 0.5;
//High priority handlers to deal with admin requests and system table operation requests
@@ -950,8 +949,7 @@ public final class HConstants {
public static final String DEFAULT_WAL_STORAGE_POLICY = "NONE";
/** Region in Transition metrics threshold time */
- public static final String METRICS_RIT_STUCK_WARNING_THRESHOLD =
- "hbase.metrics.rit.stuck.warning.threshold";
+ public static final String METRICS_RIT_STUCK_WARNING_THRESHOLD="hbase.metrics.rit.stuck.warning.threshold";
public static final String LOAD_BALANCER_SLOP_KEY = "hbase.regions.slop";
@@ -1046,8 +1044,7 @@ public final class HConstants {
* 0.0.0.0.
* @see <a href="https://issues.apache.org/jira/browse/HBASE-9961">HBASE-9961</a>
*/
- public static final String STATUS_MULTICAST_BIND_ADDRESS =
- "hbase.status.multicast.bind.address.ip";
+ public static final String STATUS_MULTICAST_BIND_ADDRESS = "hbase.status.multicast.bind.address.ip";
public static final String DEFAULT_STATUS_MULTICAST_BIND_ADDRESS = "0.0.0.0";
/**
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java
----------------------------------------------------------------------
diff --git a/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java b/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java
index 93f98ac..e0c3bae 100644
--- a/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java
+++ b/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java
@@ -46,6 +46,7 @@ import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.Bu
import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter;
import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.OperationStatus;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
@@ -136,7 +137,7 @@ public class BulkDeleteEndpoint extends BulkDeleteService implements Coprocessor
List<List<Cell>> deleteRows = new ArrayList<List<Cell>>(rowBatchSize);
for (int i = 0; i < rowBatchSize; i++) {
List<Cell> results = new ArrayList<Cell>();
- hasMore = scanner.next(results);
+ hasMore = NextState.hasMoreValues(scanner.next(results));
if (results.size() > 0) {
deleteRows.add(results);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java
----------------------------------------------------------------------
diff --git a/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java b/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java
index 4309cdc..2afd05e 100644
--- a/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java
+++ b/hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java
@@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.coprocessor.example.generated.ExampleProtos;
import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.RpcCallback;
@@ -80,7 +81,7 @@ public class RowCountEndpoint extends ExampleProtos.RowCountService
byte[] lastRow = null;
long count = 0;
do {
- hasMore = scanner.next(results);
+ hasMore = NextState.hasMoreValues(scanner.next(results));
for (Cell kv : results) {
byte[] currentRow = CellUtil.cloneRow(kv);
if (lastRow == null || !Bytes.equals(lastRow, currentRow)) {
@@ -119,7 +120,7 @@ public class RowCountEndpoint extends ExampleProtos.RowCountService
boolean hasMore = false;
long count = 0;
do {
- hasMore = scanner.next(results);
+ hasMore = NextState.hasMoreValues(scanner.next(results));
for (Cell kv : results) {
count++;
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java
index 04b88e9..a80a07e 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java
@@ -22,6 +22,7 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
+import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
@@ -29,10 +30,8 @@ import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HRegionInfo;
import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.client.metrics.ScanMetrics;
import org.apache.hadoop.hbase.regionserver.HRegion;
-import org.apache.hadoop.hbase.regionserver.NoLimitScannerContext;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.mortbay.log.Log;
@@ -73,7 +72,10 @@ public class ClientSideRegionScanner extends AbstractClientScanner {
public Result next() throws IOException {
values.clear();
- scanner.nextRaw(values, NoLimitScannerContext.NO_LIMIT);
+ // negative values indicate no limits
+ final long remainingResultSize = -1;
+ final int batchLimit = -1;
+ scanner.nextRaw(values, batchLimit, remainingResultSize);
if (values.isEmpty()) {
//we are done
return null;
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java
index 81c933b..b6f834e 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/AggregateImplementation.java
@@ -38,6 +38,7 @@ import org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateReque
import org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateResponse;
import org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateService;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import com.google.protobuf.ByteString;
import com.google.protobuf.Message;
@@ -91,7 +92,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
// qualifier can be null.
boolean hasMoreRows = false;
do {
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
temp = ci.getValue(colFamily, qualifier, results.get(i));
@@ -145,7 +146,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
}
boolean hasMoreRows = false;
do {
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
temp = ci.getValue(colFamily, qualifier, results.get(i));
@@ -199,7 +200,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
List<Cell> results = new ArrayList<Cell>();
boolean hasMoreRows = false;
do {
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
temp = ci.getValue(colFamily, qualifier, results.get(i));
@@ -253,7 +254,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
scanner = env.getRegion().getScanner(scan);
boolean hasMoreRows = false;
do {
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
if (results.size() > 0) {
counter++;
}
@@ -312,7 +313,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
do {
results.clear();
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
sumVal = ci.add(sumVal, ci.castToReturnType(ci.getValue(colFamily,
@@ -373,7 +374,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
do {
tempVal = null;
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
tempVal = ci.add(tempVal, ci.castToReturnType(ci.getValue(colFamily,
@@ -440,7 +441,7 @@ extends AggregateService implements CoprocessorService, Coprocessor {
do {
tempVal = null;
tempWeight = null;
- hasMoreRows = scanner.next(results);
+ hasMoreRows = NextState.hasMoreValues(scanner.next(results));
int listSize = results.size();
for (int i = 0; i < listSize; i++) {
Cell kv = results.get(i);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
index e082698..4a8e7cc 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
@@ -141,9 +141,8 @@ import org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor.Stor
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor;
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor.EventType;
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.StoreDescriptor;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl.WriteEntry;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.NextState;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionContext;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionThroughputController;
import org.apache.hadoop.hbase.regionserver.compactions.CompactionThroughputControllerFactory;
@@ -5176,7 +5175,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
protected Cell joinedContinuationRow = null;
protected final byte[] stopRow;
private final FilterWrapper filter;
- private ScannerContext defaultScannerContext;
+ private int batch;
protected int isScan;
private boolean filterClosed = false;
private long readPt;
@@ -5199,13 +5198,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
this.filter = null;
}
- /**
- * By default, calls to next/nextRaw must enforce the batch limit. Thus, construct a default
- * scanner context that can be used to enforce the batch limit in the event that a
- * ScannerContext is not specified during an invocation of next/nextRaw
- */
- defaultScannerContext = ScannerContext.newBuilder().setBatchLimit(scan.getBatch()).build();
-
+ this.batch = scan.getBatch();
if (Bytes.equals(scan.getStopRow(), HConstants.EMPTY_END_ROW) && !scan.isGetScan()) {
this.stopRow = null;
} else {
@@ -5266,7 +5259,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
@Override
public int getBatch() {
- return this.defaultScannerContext.getBatchLimit();
+ return this.batch;
}
/**
@@ -5281,14 +5274,19 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
}
@Override
- public boolean next(List<Cell> outResults)
+ public NextState next(List<Cell> outResults)
throws IOException {
// apply the batching limit by default
- return next(outResults, defaultScannerContext);
+ return next(outResults, batch);
+ }
+
+ @Override
+ public NextState next(List<Cell> outResults, int limit) throws IOException {
+ return next(outResults, limit, -1);
}
@Override
- public synchronized boolean next(List<Cell> outResults, ScannerContext scannerContext)
+ public synchronized NextState next(List<Cell> outResults, int limit, long remainingResultSize)
throws IOException {
if (this.filterClosed) {
throw new UnknownScannerException("Scanner was closed (timed out?) " +
@@ -5298,107 +5296,122 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
startRegionOperation(Operation.SCAN);
readRequestsCount.increment();
try {
- return nextRaw(outResults, scannerContext);
+ return nextRaw(outResults, limit, remainingResultSize);
} finally {
closeRegionOperation(Operation.SCAN);
}
}
@Override
- public boolean nextRaw(List<Cell> outResults) throws IOException {
- // Use the RegionScanner's context by default
- return nextRaw(outResults, defaultScannerContext);
+ public NextState nextRaw(List<Cell> outResults) throws IOException {
+ return nextRaw(outResults, batch);
}
@Override
- public boolean nextRaw(List<Cell> outResults, ScannerContext scannerContext)
+ public NextState nextRaw(List<Cell> outResults, int limit)
+ throws IOException {
+ return nextRaw(outResults, limit, -1);
+ }
+
+ @Override
+ public NextState nextRaw(List<Cell> outResults, int batchLimit, long remainingResultSize)
throws IOException {
if (storeHeap == null) {
// scanner is closed
throw new UnknownScannerException("Scanner was closed");
}
- boolean moreValues;
+ NextState state;
if (outResults.isEmpty()) {
// Usually outResults is empty. This is true when next is called
// to handle scan or get operation.
- moreValues = nextInternal(outResults, scannerContext);
+ state = nextInternal(outResults, batchLimit, remainingResultSize);
} else {
List<Cell> tmpList = new ArrayList<Cell>();
- moreValues = nextInternal(tmpList, scannerContext);
+ state = nextInternal(tmpList, batchLimit, remainingResultSize);
outResults.addAll(tmpList);
}
+ // Invalid states should never be returned. Receiving an invalid state means that we have
+ // no clue how to proceed. Throw an exception.
+ if (!NextState.isValidState(state)) {
+ throw new IOException("Invalid state returned from nextInternal. state:" + state);
+ }
// If the size limit was reached it means a partial Result is being returned. Returning a
// partial Result means that we should not reset the filters; filters should only be reset in
// between rows
- if (!scannerContext.partialResultFormed()) resetFilters();
+ if (!state.sizeLimitReached()) resetFilters();
if (isFilterDoneInternal()) {
- moreValues = false;
+ state = NextState.makeState(NextState.State.NO_MORE_VALUES, state.getResultSize());
}
- return moreValues;
+ return state;
}
/**
- * @return true if more cells exist after this batch, false if scanner is done
+ * @return the state the joinedHeap returned on the call to
+ * {@link KeyValueHeap#next(List, int, long)}
*/
- private boolean populateFromJoinedHeap(List<Cell> results, ScannerContext scannerContext)
+ private NextState populateFromJoinedHeap(List<Cell> results, int limit, long resultSize)
throws IOException {
assert joinedContinuationRow != null;
- boolean moreValues =
- populateResult(results, this.joinedHeap, scannerContext,
+ NextState state =
+ populateResult(results, this.joinedHeap, limit, resultSize,
joinedContinuationRow.getRowArray(), joinedContinuationRow.getRowOffset(),
joinedContinuationRow.getRowLength());
-
- if (!scannerContext.checkAnyLimitReached(LimitScope.BETWEEN_CELLS)) {
+ if (state != null && !state.batchLimitReached() && !state.sizeLimitReached()) {
// We are done with this row, reset the continuation.
joinedContinuationRow = null;
}
// As the data is obtained from two independent heaps, we need to
// ensure that result list is sorted, because Result relies on that.
Collections.sort(results, comparator);
- return moreValues;
+ return state;
}
/**
* Fetches records with currentRow into results list, until next row, batchLimit (if not -1) is
* reached, or remainingResultSize (if not -1) is reaced
* @param heap KeyValueHeap to fetch data from.It must be positioned on correct row before call.
- * @param scannerContext
+ * @param remainingResultSize The remaining space within our result size limit. A negative value
+ * indicate no limit
+ * @param batchLimit Max amount of KVs to place in result list, -1 means no limit.
* @param currentRow Byte array with key we are fetching.
* @param offset offset for currentRow
* @param length length for currentRow
* @return state of last call to {@link KeyValueHeap#next()}
*/
- private boolean populateResult(List<Cell> results, KeyValueHeap heap,
- ScannerContext scannerContext, byte[] currentRow, int offset, short length)
- throws IOException {
+ private NextState populateResult(List<Cell> results, KeyValueHeap heap, int batchLimit,
+ long remainingResultSize, byte[] currentRow, int offset, short length) throws IOException {
Cell nextKv;
boolean moreCellsInRow = false;
- boolean tmpKeepProgress = scannerContext.getKeepProgress();
- // Scanning between column families and thus the scope is between cells
- LimitScope limitScope = LimitScope.BETWEEN_CELLS;
+ long accumulatedResultSize = 0;
+ List<Cell> tmpResults = new ArrayList<Cell>();
do {
- // We want to maintain any progress that is made towards the limits while scanning across
- // different column families. To do this, we toggle the keep progress flag on during calls
- // to the StoreScanner to ensure that any progress made thus far is not wiped away.
- scannerContext.setKeepProgress(true);
- heap.next(results, scannerContext);
- scannerContext.setKeepProgress(tmpKeepProgress);
+ int remainingBatchLimit = batchLimit - results.size();
+ NextState heapState =
+ heap.next(tmpResults, remainingBatchLimit, remainingResultSize - accumulatedResultSize);
+ results.addAll(tmpResults);
+ accumulatedResultSize += calculateResultSize(tmpResults, heapState);
+ tmpResults.clear();
+
+ if (batchLimit > 0 && results.size() == batchLimit) {
+ return NextState.makeState(NextState.State.BATCH_LIMIT_REACHED, accumulatedResultSize);
+ }
nextKv = heap.peek();
moreCellsInRow = moreCellsInRow(nextKv, currentRow, offset, length);
-
- if (scannerContext.checkBatchLimit(limitScope)) {
- return scannerContext.setScannerState(NextState.BATCH_LIMIT_REACHED).hasMoreValues();
- } else if (scannerContext.checkSizeLimit(limitScope)) {
- ScannerContext.NextState state =
- moreCellsInRow ? NextState.SIZE_LIMIT_REACHED_MID_ROW : NextState.SIZE_LIMIT_REACHED;
- return scannerContext.setScannerState(state).hasMoreValues();
+ boolean sizeLimitReached =
+ remainingResultSize > 0 && accumulatedResultSize >= remainingResultSize;
+ if (moreCellsInRow && sizeLimitReached) {
+ return NextState.makeState(NextState.State.SIZE_LIMIT_REACHED, accumulatedResultSize);
}
} while (moreCellsInRow);
- return nextKv != null;
+ if (nextKv != null) {
+ return NextState.makeState(NextState.State.MORE_VALUES, accumulatedResultSize);
+ } else {
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, accumulatedResultSize);
+ }
}
/**
@@ -5416,6 +5429,30 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
return nextKv != null && CellUtil.matchingRow(nextKv, currentRow, offset, length);
}
+ /**
+ * Calculates the size of the results. If the state of the scanner that these results came from
+ * indicates that an estimate of the result size has already been generated, we can skip the
+ * calculation and use that instead.
+ * @param results List of cells we want to calculate size of
+ * @param state The state returned from the scanner that generated these results
+ * @return aggregate size of results
+ */
+ private long calculateResultSize(List<Cell> results, NextState state) {
+ if (results == null || results.isEmpty()) return 0;
+
+ // In general, the state should contain the estimate because the result size used to
+ // determine when the scan has exceeded its size limit. If the estimate is contained in the
+ // state then we can avoid an unnecesasry calculation.
+ if (state != null && state.hasResultSizeEstimate()) return state.getResultSize();
+
+ long size = 0;
+ for (Cell c : results) {
+ size += CellUtil.estimatedHeapSizeOfWithoutTags(c);
+ }
+
+ return size;
+ }
+
/*
* @return True if a filter rules the scanner is over, done.
*/
@@ -5428,37 +5465,20 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
return this.filter != null && this.filter.filterAllRemaining();
}
- private boolean nextInternal(List<Cell> results, ScannerContext scannerContext)
+ private NextState nextInternal(List<Cell> results, int batchLimit, long remainingResultSize)
throws IOException {
if (!results.isEmpty()) {
throw new IllegalArgumentException("First parameter should be an empty list");
}
- if (scannerContext == null) {
- throw new IllegalArgumentException("Scanner context cannot be null");
- }
+ // Estimate of the size (heap size) of the results returned from this method
+ long resultSize = 0;
RpcCallContext rpcCall = RpcServer.getCurrentCall();
-
- // Save the initial progress from the Scanner context in these local variables. The progress
- // may need to be reset a few times if rows are being filtered out so we save the initial
- // progress.
- int initialBatchProgress = scannerContext.getBatchProgress();
- long initialSizeProgress = scannerContext.getSizeProgress();
-
// The loop here is used only when at some point during the next we determine
// that due to effects of filters or otherwise, we have an empty row in the result.
// Then we loop and try again. Otherwise, we must get out on the first iteration via return,
// "true" if there's more data to read, "false" if there isn't (storeHeap is at a stop row,
// and joinedHeap has no more data to read for the last row (if set, joinedContinuationRow).
while (true) {
- // Starting to scan a new row. Reset the scanner progress according to whether or not
- // progress should be kept.
- if (scannerContext.getKeepProgress()) {
- // Progress should be kept. Reset to initial values seen at start of method invocation.
- scannerContext.setProgress(initialBatchProgress, initialSizeProgress);
- } else {
- scannerContext.clearProgress();
- }
-
if (rpcCall != null) {
// If a user specifies a too-restrictive or too-slow scanner, the
// client might time out and disconnect while the server side
@@ -5486,24 +5506,21 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
}
boolean stopRow = isStopRow(currentRow, offset, length);
- // When has filter row is true it means that the all the cells for a particular row must be
- // read before a filtering decision can be made. This means that filters where hasFilterRow
- // run the risk of encountering out of memory errors in the case that they are applied to a
- // table that has very large rows.
boolean hasFilterRow = this.filter != null && this.filter.hasFilterRow();
// If filter#hasFilterRow is true, partial results are not allowed since allowing them
// would prevent the filters from being evaluated. Thus, if it is true, change the
- // scope of any limits that could potentially create partial results to
- // LimitScope.BETWEEN_ROWS so that those limits are not reached mid-row
- if (hasFilterRow) {
+ // remainingResultSize to -1 so that the entire row's worth of cells are fetched.
+ if (hasFilterRow && remainingResultSize > 0) {
+ remainingResultSize = -1;
if (LOG.isTraceEnabled()) {
- LOG.trace("filter#hasFilterRow is true which prevents partial results from being "
- + " formed. Changing scope of limits that may create partials");
+ LOG.trace("filter#hasFilterRow is true which prevents partial results from being " +
+ " formed. The remainingResultSize of: " + remainingResultSize + " will not " +
+ " be considered when fetching the cells for this row.");
}
- scannerContext.setSizeLimitScope(LimitScope.BETWEEN_ROWS);
}
+ NextState joinedHeapState;
// Check if we were getting data from the joinedHeap and hit the limit.
// If not, then it's main path - getting results from storeHeap.
if (joinedContinuationRow == null) {
@@ -5512,30 +5529,47 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
if (hasFilterRow) {
filter.filterRowCells(results);
}
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, resultSize);
}
// Check if rowkey filter wants to exclude this row. If so, loop to next.
// Technically, if we hit limits before on this row, we don't need this call.
if (filterRowKey(currentRow, offset, length)) {
boolean moreRows = nextRow(currentRow, offset, length);
- if (!moreRows) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
- }
+ if (!moreRows) return NextState.makeState(NextState.State.NO_MORE_VALUES, resultSize);
results.clear();
continue;
}
- // Ok, we are good, let's try to get some results from the main heap.
- populateResult(results, this.storeHeap, scannerContext, currentRow, offset, length);
+ NextState storeHeapState =
+ populateResult(results, this.storeHeap, batchLimit, remainingResultSize, currentRow,
+ offset, length);
+ resultSize += calculateResultSize(results, storeHeapState);
+ // Invalid states should never be returned. If one is seen, throw exception
+ // since we have no way of telling how we should proceed
+ if (!NextState.isValidState(storeHeapState)) {
+ throw new IOException("NextState returned from call storeHeap was invalid");
+ }
- if (scannerContext.checkAnyLimitReached(LimitScope.BETWEEN_CELLS)) {
+ // Ok, we are good, let's try to get some results from the main heap.
+ if (storeHeapState.batchLimitReached()) {
if (hasFilterRow) {
throw new IncompatibleFilterException(
- "Filter whose hasFilterRow() returns true is incompatible with scans that must "
- + " stop mid-row because of a limit. ScannerContext:" + scannerContext);
+ "Filter whose hasFilterRow() returns true is incompatible with scan with limit!");
}
- return true;
+ // We hit the batch limit.
+ return NextState.makeState(NextState.State.BATCH_LIMIT_REACHED, resultSize);
+ } else if (storeHeapState.sizeLimitReached()) {
+ if (hasFilterRow) {
+ // We try to guard against this case above when remainingResultSize is set to -1 if
+ // hasFilterRow is true. In the even that the guard doesn't work, an exception must be
+ // thrown
+ throw new IncompatibleFilterException(
+ "Filter whose hasFilterRows() returns true is incompatible with scans that"
+ + " return partial results");
+ }
+ // We hit the size limit.
+ return NextState.makeState(NextState.State.SIZE_LIMIT_REACHED, resultSize);
}
Cell nextKv = this.storeHeap.peek();
stopRow = nextKv == null ||
@@ -5548,31 +5582,17 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
FilterWrapper.FilterRowRetCode ret = FilterWrapper.FilterRowRetCode.NOT_CALLED;
if (hasFilterRow) {
ret = filter.filterRowCellsWithRet(results);
-
- // We don't know how the results have changed after being filtered. Must set progress
- // according to contents of results now.
- if (scannerContext.getKeepProgress()) {
- scannerContext.setProgress(initialBatchProgress, initialSizeProgress);
- } else {
- scannerContext.clearProgress();
- }
- scannerContext.incrementBatchProgress(results.size());
- for (Cell cell : results) {
- scannerContext.incrementSizeProgress(CellUtil.estimatedHeapSizeOfWithoutTags(cell));
- }
}
if ((isEmptyRow || ret == FilterWrapper.FilterRowRetCode.EXCLUDE) || filterRow()) {
results.clear();
boolean moreRows = nextRow(currentRow, offset, length);
- if (!moreRows) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
- }
+ if (!moreRows) return NextState.makeState(NextState.State.NO_MORE_VALUES, 0);
// This row was totally filtered out, if this is NOT the last row,
// we should continue on. Otherwise, nothing else to do.
if (!stopRow) continue;
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, 0);
}
// Ok, we are done with storeHeap for this row.
@@ -5590,24 +5610,31 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
currentRow, offset, length));
if (mayHaveData) {
joinedContinuationRow = current;
- populateFromJoinedHeap(results, scannerContext);
-
- if (scannerContext.checkAnyLimitReached(LimitScope.BETWEEN_CELLS)) {
- return true;
+ joinedHeapState =
+ populateFromJoinedHeap(results, batchLimit, remainingResultSize - resultSize);
+ resultSize +=
+ joinedHeapState != null && joinedHeapState.hasResultSizeEstimate() ?
+ joinedHeapState.getResultSize() : 0;
+ if (joinedHeapState != null && joinedHeapState.sizeLimitReached()) {
+ return NextState.makeState(NextState.State.SIZE_LIMIT_REACHED, resultSize);
}
}
}
} else {
// Populating from the joined heap was stopped by limits, populate some more.
- populateFromJoinedHeap(results, scannerContext);
- if (scannerContext.checkAnyLimitReached(LimitScope.BETWEEN_CELLS)) {
- return true;
+ joinedHeapState =
+ populateFromJoinedHeap(results, batchLimit, remainingResultSize - resultSize);
+ resultSize +=
+ joinedHeapState != null && joinedHeapState.hasResultSizeEstimate() ?
+ joinedHeapState.getResultSize() : 0;
+ if (joinedHeapState != null && joinedHeapState.sizeLimitReached()) {
+ return NextState.makeState(NextState.State.SIZE_LIMIT_REACHED, resultSize);
}
}
// We may have just called populateFromJoinedMap and hit the limits. If that is
// the case, we need to call it again on the next next() invocation.
if (joinedContinuationRow != null) {
- return scannerContext.setScannerState(NextState.MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.MORE_VALUES, resultSize);
}
// Finally, we are done with both joinedHeap and storeHeap.
@@ -5615,17 +5642,15 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
// the case when SingleColumnValueExcludeFilter is used.
if (results.isEmpty()) {
boolean moreRows = nextRow(currentRow, offset, length);
- if (!moreRows) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
- }
+ if (!moreRows) return NextState.makeState(NextState.State.NO_MORE_VALUES, 0);
if (!stopRow) continue;
}
// We are done. Return the result.
if (stopRow) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, resultSize);
} else {
- return scannerContext.setScannerState(NextState.MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.MORE_VALUES, resultSize);
}
}
}
@@ -7244,7 +7269,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
boolean done;
do {
kvs.clear();
- done = scanner.next(kvs);
+ done = NextState.hasMoreValues(scanner.next(kvs));
if (kvs.size() > 0) LOG.info(kvs);
} while (done);
} finally {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/InternalScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/InternalScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/InternalScanner.java
index f73e363..ea5a75f 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/InternalScanner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/InternalScanner.java
@@ -42,21 +42,218 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience;
@InterfaceAudience.Private
public interface InternalScanner extends Closeable {
/**
+ * This class encapsulates all the meaningful state information that we would like the know about
+ * after a call to {@link InternalScanner#next(List)}. While this is not an enum, a restriction on
+ * the possible states is implied through the exposed {@link #makeState(State)} method.
+ */
+ public static class NextState {
+ /**
+ * The possible states we want to restrict ourselves to. This enum is not sufficient to
+ * encapsulate all of the state information since some of the fields of the state must be
+ * dynamic (e.g. resultSize).
+ */
+ public enum State {
+ MORE_VALUES(true),
+ NO_MORE_VALUES(false),
+ SIZE_LIMIT_REACHED(true),
+ BATCH_LIMIT_REACHED(true);
+
+ private boolean moreValues;
+
+ private State(final boolean moreValues) {
+ this.moreValues = moreValues;
+ }
+
+ /**
+ * @return true when the state indicates that more values may follow those that have been
+ * returned
+ */
+ public boolean hasMoreValues() {
+ return this.moreValues;
+ }
+ }
+
+ /**
+ * state variables
+ */
+ private final State state;
+ private long resultSize;
+
+ /**
+ * Value to use for resultSize when the size has not been calculated. Must be a negative number
+ * so that {@link NextState#hasResultSizeEstimate()} returns false.
+ */
+ private static final long DEFAULT_RESULT_SIZE = -1;
+
+ private NextState(State state, long resultSize) {
+ this.state = state;
+ this.resultSize = resultSize;
+ }
+
+ /**
+ * @param state
+ * @return An instance of {@link NextState} where the size of the results returned from the call
+ * to {@link InternalScanner#next(List)} is unknown. It it the responsibility of the
+ * caller of {@link InternalScanner#next(List)} to calculate the result size if needed
+ */
+ public static NextState makeState(final State state) {
+ return makeState(state, DEFAULT_RESULT_SIZE);
+ }
+
+ /**
+ * @param state
+ * @param resultSize
+ * @return An instance of {@link NextState} where the size of the values returned from the call
+ * to {@link InternalScanner#next(List)} is known. The caller can avoid recalculating
+ * the result size by using the cached value retrievable via {@link #getResultSize()}
+ */
+ public static NextState makeState(final State state, long resultSize) {
+ switch (state) {
+ case MORE_VALUES:
+ return createMoreValuesState(resultSize);
+ case NO_MORE_VALUES:
+ return createNoMoreValuesState(resultSize);
+ case BATCH_LIMIT_REACHED:
+ return createBatchLimitReachedState(resultSize);
+ case SIZE_LIMIT_REACHED:
+ return createSizeLimitReachedState(resultSize);
+ default:
+ // If the state is not recognized, default to no more value state
+ return createNoMoreValuesState(resultSize);
+ }
+ }
+
+ /**
+ * Convenience method for creating a state that indicates that more values can be scanned
+ * @param resultSize estimate of the size (heap size) of the values returned from the call to
+ * {@link InternalScanner#next(List)}
+ */
+ private static NextState createMoreValuesState(long resultSize) {
+ return new NextState(State.MORE_VALUES, resultSize);
+ }
+
+ /**
+ * Convenience method for creating a state that indicates that no more values can be scanned.
+ * @param resultSize estimate of the size (heap size) of the values returned from the call to
+ * {@link InternalScanner#next(List)}
+ */
+ private static NextState createNoMoreValuesState(long resultSize) {
+ return new NextState(State.NO_MORE_VALUES, resultSize);
+ }
+
+ /**
+ * Convenience method for creating a state that indicates that the scan stopped because the
+ * batch limit was exceeded
+ * @param resultSize estimate of the size (heap size) of the values returned from the call to
+ * {@link InternalScanner#next(List)}
+ */
+ private static NextState createBatchLimitReachedState(long resultSize) {
+ return new NextState(State.BATCH_LIMIT_REACHED, resultSize);
+ }
+
+ /**
+ * Convenience method for creating a state that indicates that the scan stopped due to the size
+ * limit
+ * @param resultSize estimate of the size (heap size) of the values returned from the call to
+ * {@link InternalScanner#next(List)}
+ */
+ private static NextState createSizeLimitReachedState(long resultSize) {
+ return new NextState(State.SIZE_LIMIT_REACHED, resultSize);
+ }
+
+ /**
+ * @return true when the scanner has more values to be scanned following the values returned by
+ * the call to {@link InternalScanner#next(List)}
+ */
+ public boolean hasMoreValues() {
+ return this.state.hasMoreValues();
+ }
+
+ /**
+ * @return true when the scanner had to stop scanning because it reached the batch limit
+ */
+ public boolean batchLimitReached() {
+ return this.state == State.BATCH_LIMIT_REACHED;
+ }
+
+ /**
+ * @return true when the scanner had to stop scanning because it reached the size limit
+ */
+ public boolean sizeLimitReached() {
+ return this.state == State.SIZE_LIMIT_REACHED;
+ }
+
+ /**
+ * @return The size (heap size) of the values that were returned from the call to
+ * {@link InternalScanner#next(List)}. This value should only be used if
+ * {@link #hasResultSizeEstimate()} returns true.
+ */
+ public long getResultSize() {
+ return resultSize;
+ }
+
+ /**
+ * @return true when an estimate for the size of the values returned by
+ * {@link InternalScanner#next(List)} was provided. If false, it is the responsibility
+ * of the caller to calculate the result size
+ */
+ public boolean hasResultSizeEstimate() {
+ return resultSize >= 0;
+ }
+
+ @Override
+ public String toString() {
+ return "State: " + state + " resultSize: " + resultSize;
+ }
+
+ /**
+ * Helper method to centralize all checks as to whether or not the state is valid.
+ * @param state
+ * @return true when the state is valid
+ */
+ public static boolean isValidState(NextState state) {
+ return state != null;
+ }
+
+ /**
+ * @param state
+ * @return true when the state is non null and indicates that more values exist
+ */
+ public static boolean hasMoreValues(NextState state) {
+ return state != null && state.hasMoreValues();
+ }
+ }
+
+ /**
* Grab the next row's worth of values.
* @param results return output array
- * @return true if more rows exist after this one, false if scanner is done
+ * @return state where {@link NextState#hasMoreValues()} is true if more rows exist after this
+ * one, false if scanner is done
* @throws IOException e
*/
- boolean next(List<Cell> results) throws IOException;
+ NextState next(List<Cell> results) throws IOException;
/**
- * Grab the next row's worth of values.
+ * Grab the next row's worth of values with a limit on the number of values to return.
+ * @param result return output array
+ * @param limit limit on row count to get
+ * @return state where {@link NextState#hasMoreValues()} is true if more rows exist after this
+ * one, false if scanner is done
+ * @throws IOException e
+ */
+ NextState next(List<Cell> result, int limit) throws IOException;
+
+ /**
+ * Grab the next row's worth of values with a limit on the number of values to return as well as a
+ * restriction on the size of the list of values that are returned.
* @param result return output array
- * @param scannerContext
- * @return true if more rows exist after this one, false if scanner is done
+ * @param limit limit on row count to get
+ * @param remainingResultSize limit on the size of the result being returned
+ * @return state where {@link NextState#hasMoreValues()} is true if more rows exist after this
+ * one, false if scanner is done
* @throws IOException e
*/
- boolean next(List<Cell> result, ScannerContext scannerContext) throws IOException;
+ NextState next(List<Cell> result, int limit, long remainingResultSize) throws IOException;
/**
* Closes the scanner and releases any resources it has allocated
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java
index 6e7788a..beb23cf 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java
@@ -27,7 +27,6 @@ import java.util.PriorityQueue;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.KeyValue.KVComparator;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.NextState;
/**
* Implements a heap merge across any number of KeyValueScanners.
@@ -129,20 +128,26 @@ public class KeyValueHeap extends NonReversedNonLazyKeyValueScanner
* This can ONLY be called when you are using Scanners that implement InternalScanner as well as
* KeyValueScanner (a {@link StoreScanner}).
* @param result
- * @return true if more rows exist after this one, false if scanner is done
+ * @param limit
+ * @return state where NextState#hasMoreValues() is true if more keys exist after this
+ * one, false if scanner is done
*/
- @Override
- public boolean next(List<Cell> result) throws IOException {
- return next(result, NoLimitScannerContext.NO_LIMIT);
+ public NextState next(List<Cell> result, int limit) throws IOException {
+ return next(result, limit, -1);
}
- @Override
- public boolean next(List<Cell> result, ScannerContext scannerContext) throws IOException {
+ public NextState next(List<Cell> result, int limit, long remainingResultSize) throws IOException {
if (this.current == null) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES);
}
InternalScanner currentAsInternal = (InternalScanner)this.current;
- boolean moreCells = currentAsInternal.next(result, scannerContext);
+ NextState state = currentAsInternal.next(result, limit, remainingResultSize);
+ // Invalid states should never be returned. Receiving an invalid state means that we have
+ // no clue how to proceed. Throw an exception.
+ if (!NextState.isValidState(state)) {
+ throw new IOException("Invalid state returned from InternalScanner#next");
+ }
+ boolean mayContainMoreRows = NextState.hasMoreValues(state);
Cell pee = this.current.peek();
/*
* By definition, any InternalScanner must return false only when it has no
@@ -151,16 +156,31 @@ public class KeyValueHeap extends NonReversedNonLazyKeyValueScanner
* more efficient to close scanners which are not needed than keep them in
* the heap. This is also required for certain optimizations.
*/
- if (pee == null || !moreCells) {
+ if (pee == null || !mayContainMoreRows) {
this.current.close();
} else {
this.heap.add(this.current);
}
this.current = pollRealKV();
if (this.current == null) {
- moreCells = scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ state = NextState.makeState(NextState.State.NO_MORE_VALUES, state.getResultSize());
}
- return moreCells;
+ return state;
+ }
+
+ /**
+ * Gets the next row of keys from the top-most scanner.
+ * <p>
+ * This method takes care of updating the heap.
+ * <p>
+ * This can ONLY be called when you are using Scanners that implement InternalScanner as well as
+ * KeyValueScanner (a {@link StoreScanner}).
+ * @param result
+ * @return state where NextState#hasMoreValues() is true if more keys exist after this
+ * one, false if scanner is done
+ */
+ public NextState next(List<Cell> result) throws IOException {
+ return next(result, -1);
}
protected static class KVScannerComparator implements Comparator<KeyValueScanner> {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NoLimitScannerContext.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NoLimitScannerContext.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NoLimitScannerContext.java
deleted file mode 100644
index 99a371a..0000000
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/NoLimitScannerContext.java
+++ /dev/null
@@ -1,94 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.hadoop.hbase.regionserver;
-
-import org.apache.hadoop.hbase.HBaseInterfaceAudience;
-import org.apache.hadoop.hbase.classification.InterfaceAudience;
-import org.apache.hadoop.hbase.classification.InterfaceStability;
-
-/**
- * This is a special {@link ScannerContext} subclass that is designed to be used globally when
- * limits should not be enforced during invocations of {@link InternalScanner#next(java.util.List)}
- * or {@link RegionScanner#next(java.util.List)}.
- * <p>
- * Instances of {@link NoLimitScannerContext} are immutable after construction. Any attempt to
- * change the limits or progress of a {@link NoLimitScannerContext} will fail silently. The net
- * effect is that all limit checks will return false, thus indicating that a limit has not been
- * reached.
- */
-@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
-@InterfaceStability.Evolving
-public class NoLimitScannerContext extends ScannerContext {
-
- public NoLimitScannerContext() {
- super(false, null);
- }
-
- /**
- * Use this instance whenever limits do not need to be enforced.
- */
- public static ScannerContext NO_LIMIT = new NoLimitScannerContext();
-
- @Override
- void setKeepProgress(boolean keepProgress) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- }
-
- @Override
- void setBatchProgress(int batchProgress) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- }
-
- @Override
- void setSizeProgress(long sizeProgress) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- }
-
- @Override
- void setProgress(int batchProgress, long sizeProgress) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- }
-
- @Override
- void setSizeLimitScope(LimitScope scope) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- }
-
- @Override
- NextState setScannerState(NextState state) {
- // Do nothing. NoLimitScannerContext instances are immutable post-construction
- return state;
- }
-
- @Override
- boolean checkBatchLimit(LimitScope checkerScope) {
- // No limits can be specified, thus return false to indicate no limit has been reached.
- return false;
- }
-
- @Override
- boolean checkSizeLimit(LimitScope checkerScope) {
- // No limits can be specified, thus return false to indicate no limit has been reached.
- return false;
- }
-
- @Override
- boolean checkAnyLimitReached(LimitScope checkerScope) {
- return false;
- }
-}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
index 10e39a1..1508a15 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
@@ -105,6 +105,8 @@ import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest.RegionOpenInfo;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionResponse.RegionOpeningState;
+import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionRequest;
+import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryRequest;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.RollWALWriterRequest;
@@ -118,8 +120,6 @@ import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateConfiguratio
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry;
-import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionRequest;
-import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WarmupRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.ClientProtos;
import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest;
import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.BulkLoadHFileRequest.FamilyPath;
@@ -151,10 +151,10 @@ import org.apache.hadoop.hbase.protobuf.generated.WALProtos.FlushDescriptor;
import org.apache.hadoop.hbase.protobuf.generated.WALProtos.RegionEventDescriptor;
import org.apache.hadoop.hbase.quotas.OperationQuota;
import org.apache.hadoop.hbase.quotas.RegionServerQuotaManager;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException;
import org.apache.hadoop.hbase.regionserver.Region.FlushResult;
import org.apache.hadoop.hbase.regionserver.Region.Operation;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope;
import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler;
import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler;
import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
@@ -2236,53 +2236,61 @@ public class RSRpcServices implements HBaseRPCErrorHandler,
// correct ordering of partial results and so we prevent partial results from being
// formed.
boolean serverGuaranteesOrderOfPartials = currentScanResultSize == 0;
- boolean allowPartialResults =
+ boolean enforceMaxResultSizeAtCellLevel =
clientHandlesPartials && serverGuaranteesOrderOfPartials && !isSmallScan;
- boolean moreRows = false;
-
- final LimitScope sizeScope =
- allowPartialResults ? LimitScope.BETWEEN_CELLS : LimitScope.BETWEEN_ROWS;
-
- // Configure with limits for this RPC. Set keep progress true since size progress
- // towards size limit should be kept between calls to nextRaw
- ScannerContext.Builder contextBuilder = ScannerContext.newBuilder(true);
- contextBuilder.setSizeLimit(sizeScope, maxResultSize);
- contextBuilder.setBatchLimit(scanner.getBatch());
- ScannerContext scannerContext = contextBuilder.build();
+ NextState state = null;
while (i < rows) {
// Stop collecting results if we have exceeded maxResultSize
- if (scannerContext.checkSizeLimit(LimitScope.BETWEEN_ROWS)) {
+ if (currentScanResultSize >= maxResultSize) {
builder.setMoreResultsInRegion(true);
break;
}
- // Reset the batch progress to 0 before every call to RegionScanner#nextRaw. The
- // batch limit is a limit on the number of cells per Result. Thus, if progress is
- // being tracked (i.e. scannerContext.keepProgress() is true) then we need to
- // reset the batch progress between nextRaw invocations since we don't want the
- // batch progress from previous calls to affect future calls
- scannerContext.setBatchProgress(0);
+ // A negative remainingResultSize communicates that there is no limit on the size
+ // of the results.
+ final long remainingResultSize =
+ enforceMaxResultSizeAtCellLevel ? maxResultSize - currentScanResultSize
+ : -1;
// Collect values to be returned here
- moreRows = scanner.nextRaw(values, scannerContext);
-
+ state = scanner.nextRaw(values, scanner.getBatch(), remainingResultSize);
+ // Invalid states should never be returned. If one is seen, throw exception
+ // to stop the scan -- We have no way of telling how we should proceed
+ if (!NextState.isValidState(state)) {
+ throw new IOException("NextState returned from call to nextRaw was invalid");
+ }
if (!values.isEmpty()) {
+ // The state should always contain an estimate of the result size because that
+ // estimate must be used to decide when partial results are formed.
+ boolean skipResultSizeCalculation = state.hasResultSizeEstimate();
+ if (skipResultSizeCalculation) currentScanResultSize += state.getResultSize();
+
for (Cell cell : values) {
totalCellSize += CellUtil.estimatedSerializedSizeOf(cell);
+
+ // If the calculation can't be skipped, then do it now.
+ if (!skipResultSizeCalculation) {
+ currentScanResultSize += CellUtil.estimatedHeapSizeOfWithoutTags(cell);
+ }
}
- final boolean partial = scannerContext.partialResultFormed();
+ // The size limit was reached. This means there are more cells remaining in
+ // the row but we had to stop because we exceeded our max result size. This
+ // indicates that we are returning a partial result
+ final boolean partial = state != null && state.sizeLimitReached();
results.add(Result.create(values, null, stale, partial));
i++;
}
- if (!moreRows) {
+ if (!NextState.hasMoreValues(state)) {
break;
}
values.clear();
}
-
- if (scannerContext.checkSizeLimit(LimitScope.BETWEEN_ROWS) || i >= rows ||
- moreRows) {
+ // currentScanResultSize >= maxResultSize should be functionally equivalent to
+ // state.sizeLimitReached()
+ if (null != state
+ && (currentScanResultSize >= maxResultSize || i >= rows || state
+ .hasMoreValues())) {
// We stopped prematurely
builder.setMoreResultsInRegion(true);
} else {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java
index 66e087b..26f9aef 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionScanner.java
@@ -31,7 +31,7 @@ import org.apache.hadoop.hbase.classification.InterfaceStability;
* RegionScanner describes iterators over rows in an HRegion.
*/
@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
-@InterfaceStability.Evolving
+@InterfaceStability.Stable
public interface RegionScanner extends InternalScanner {
/**
* @return The RegionInfo for this scanner.
@@ -74,22 +74,35 @@ public interface RegionScanner extends InternalScanner {
int getBatch();
/**
- * Grab the next row's worth of values. This is a special internal method to be called from
- * coprocessor hooks to avoid expensive setup. Caller must set the thread's readpoint, start and
- * close a region operation, an synchronize on the scanner object. Caller should maintain and
- * update metrics. See {@link #nextRaw(List, ScannerContext)}
+ * Grab the next row's worth of values with the default limit on the number of values to return.
+ * This is a special internal method to be called from coprocessor hooks to avoid expensive setup.
+ * Caller must set the thread's readpoint, start and close a region operation, an synchronize on
+ * the scanner object. Caller should maintain and update metrics. See
+ * {@link #nextRaw(List, int, long)}
* @param result return output array
- * @return true if more rows exist after this one, false if scanner is done
+ * @return a state where NextState#hasMoreValues() is true when more rows exist, false when
+ * scanner is done.
* @throws IOException e
*/
- boolean nextRaw(List<Cell> result) throws IOException;
-
+ NextState nextRaw(List<Cell> result) throws IOException;
+
+ /**
+ * Grab the next row's worth of values with the default limit on the number of values to return.
+ * This is a special internal method to be called from coprocessor hooks to avoid expensive setup.
+ * Caller must set the thread's readpoint, start and close a region operation, an synchronize on
+ * the scanner object. Caller should maintain and update metrics. See
+ * {@link #nextRaw(List, int, long)}
+ * @param result return output array
+ * @param limit limit on row count to get
+ * @return a state where NextState#hasMoreValues() is true when more rows exist, false when
+ * scanner is done.
+ * @throws IOException e
+ */
+ NextState nextRaw(List<Cell> result, int limit) throws IOException;
+
/**
- * Grab the next row's worth of values. The {@link ScannerContext} is used to enforce and track
- * any limits associated with this call. Any progress that exists in the {@link ScannerContext}
- * prior to calling this method will be LOST if {@link ScannerContext#getKeepProgress()} is false.
- * Upon returning from this method, the {@link ScannerContext} will contain information about the
- * progress made towards the limits. This is a special internal method to be called from
+ * Grab the next row's worth of values with a limit on the number of values to return as well as a
+ * limit on the heap size of those values. This is a special internal method to be called from
* coprocessor hooks to avoid expensive setup. Caller must set the thread's readpoint, start and
* close a region operation, an synchronize on the scanner object. Example: <code><pre>
* HRegion region = ...;
@@ -107,12 +120,13 @@ public interface RegionScanner extends InternalScanner {
* }
* </pre></code>
* @param result return output array
- * @param scannerContext The {@link ScannerContext} instance encapsulating all limits that should
- * be tracked during calls to this method. The progress towards these limits can be
- * tracked within this instance.
- * @return true if more rows exist after this one, false if scanner is done
+ * @param limit limit on row count to get
+ * @param remainingResultSize the space remaining within the restriction on the result size.
+ * Negative values indicate no limit
+ * @return a state where NextState#hasMoreValues() is true when more rows exist, false when
+ * scanner is done.
* @throws IOException e
*/
- boolean nextRaw(List<Cell> result, ScannerContext scannerContext)
+ NextState nextRaw(List<Cell> result, int limit, final long remainingResultSize)
throws IOException;
}
[2/3] hbase git commit: Revert "HBASE-11544 [Ergonomics]
hbase.client.scanner.caching is dogged and will try to return batch even if
it means OOME" References the wrong JIRA above so revert;
also an addendum is on the way.
Posted by st...@apache.org.
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ScannerContext.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ScannerContext.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ScannerContext.java
deleted file mode 100644
index 6e487ca..0000000
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ScannerContext.java
+++ /dev/null
@@ -1,527 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.hadoop.hbase.regionserver;
-
-import java.util.List;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.hadoop.hbase.HBaseInterfaceAudience;
-import org.apache.hadoop.hbase.classification.InterfaceAudience;
-import org.apache.hadoop.hbase.classification.InterfaceStability;
-
-/**
- * ScannerContext instances encapsulate limit tracking AND progress towards those limits during
- * invocations of {@link InternalScanner#next(java.util.List)} and
- * {@link RegionScanner#next(java.util.List)}.
- * <p>
- * A ScannerContext instance should be updated periodically throughout execution whenever progress
- * towards a limit has been made. Each limit can be checked via the appropriate checkLimit method.
- * <p>
- * Once a limit has been reached, the scan will stop. The invoker of
- * {@link InternalScanner#next(java.util.List)} or {@link RegionScanner#next(java.util.List)} can
- * use the appropriate check*Limit methods to see exactly which limits have been reached.
- * Alternatively, {@link #checkAnyLimitReached(LimitScope)} is provided to see if ANY limit was
- * reached
- * <p>
- * {@link NoLimitScannerContext#NO_LIMIT} is an immutable static definition that can be used
- * whenever a {@link ScannerContext} is needed but limits do not need to be enforced.
- * <p>
- * NOTE: It is important that this class only ever expose setter methods that can be safely skipped
- * when limits should be NOT enforced. This is because of the necessary immutability of the class
- * {@link NoLimitScannerContext}. If a setter cannot be safely skipped, the immutable nature of
- * {@link NoLimitScannerContext} will lead to incorrect behavior.
- */
-@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
-@InterfaceStability.Evolving
-public class ScannerContext {
- private final Log LOG = LogFactory.getLog(this.getClass());
-
- /**
- * Two sets of the same fields. One for the limits, another for the progress towards those limits
- */
- LimitFields limits;
- LimitFields progress;
-
- /**
- * The state of the scanner after the invocation of {@link InternalScanner#next(java.util.List)}
- * or {@link RegionScanner#next(java.util.List)}.
- */
- NextState scannerState;
- private static final NextState DEFAULT_STATE = NextState.MORE_VALUES;
-
- /**
- * Used as an indication to invocations of {@link InternalScanner#next(java.util.List)} and
- * {@link RegionScanner#next(java.util.List)} that, if true, the progress tracked within this
- * {@link ScannerContext} instance should be considered while evaluating the limits. Useful for
- * enforcing a set of limits across multiple calls (i.e. the limit may not be reached in a single
- * invocation, but any progress made should be considered in future invocations)
- * <p>
- * Defaulting this value to false means that, by default, any tracked progress will be wiped clean
- * on invocations to {@link InternalScanner#next(java.util.List)} and
- * {@link RegionScanner#next(java.util.List)} and the call will be treated as though no progress
- * has been made towards the limits so far.
- * <p>
- * This is an important mechanism. Users of Internal/Region scanners expect that they can define
- * some limits and then repeatedly invoke {@link InternalScanner#next(List)} or
- * {@link RegionScanner#next(List)} where each invocation respects these limits separately.
- * <p>
- * For example: <code><pre>
- * ScannerContext context = new ScannerContext.newBuilder().setBatchLimit(5).build();
- * RegionScanner scanner = ...
- * List<Cell> results = new ArrayList<Cell>();
- * while(scanner.next(results, context)) {
- * // Do something with a batch of 5 cells
- * }
- * </pre></code> However, in the case of RPCs, the server wants to be able to define a set of
- * limits for a particular RPC request and have those limits respected across multiple
- * invocations. This means that the progress made towards the limits in earlier calls will be
- * saved and considered in future invocations
- */
- boolean keepProgress;
- private static boolean DEFAULT_KEEP_PROGRESS = false;
-
- ScannerContext(boolean keepProgress, LimitFields limitsToCopy) {
- this.limits = new LimitFields();
- if (limitsToCopy != null) this.limits.copy(limitsToCopy);
-
- // Progress fields are initialized to 0
- progress = new LimitFields(0, LimitFields.DEFAULT_SCOPE, 0);
-
- this.keepProgress = keepProgress;
- this.scannerState = DEFAULT_STATE;
- }
-
- /**
- * @return true if the progress tracked so far in this instance will be considered during an
- * invocation of {@link InternalScanner#next(java.util.List)} or
- * {@link RegionScanner#next(java.util.List)}. false when the progress tracked so far
- * should not be considered and should instead be wiped away via {@link #clearProgress()}
- */
- boolean getKeepProgress() {
- return keepProgress;
- }
-
- void setKeepProgress(boolean keepProgress) {
- this.keepProgress = keepProgress;
- }
-
- /**
- * Progress towards the batch limit has been made. Increment internal tracking of batch progress
- */
- void incrementBatchProgress(int batch) {
- int currentBatch = progress.getBatch();
- progress.setBatch(currentBatch + batch);
- }
-
- /**
- * Progress towards the size limit has been made. Increment internal tracking of size progress
- */
- void incrementSizeProgress(long size) {
- long currentSize = progress.getSize();
- progress.setSize(currentSize + size);
- }
-
- int getBatchProgress() {
- return progress.getBatch();
- }
-
- long getSizeProgress() {
- return progress.getSize();
- }
-
- void setProgress(int batchProgress, long sizeProgress) {
- setBatchProgress(batchProgress);
- setSizeProgress(sizeProgress);
- }
-
- void setSizeProgress(long sizeProgress) {
- progress.setSize(sizeProgress);
- }
-
- void setBatchProgress(int batchProgress) {
- progress.setBatch(batchProgress);
- }
-
- /**
- * Clear away any progress that has been made so far. All progress fields are reset to initial
- * values
- */
- void clearProgress() {
- progress.setFields(0, LimitFields.DEFAULT_SCOPE, 0);
- }
-
- /**
- * Note that this is not a typical setter. This setter returns the {@link NextState} that was
- * passed in so that methods can be invoked against the new state. Furthermore, this pattern
- * allows the {@link NoLimitScannerContext} to cleanly override this setter and simply return the
- * new state, thus preserving the immutability of {@link NoLimitScannerContext}
- * @param state
- * @return The state that
- */
- NextState setScannerState(NextState state) {
- if (!NextState.isValidState(state)) {
- throw new IllegalArgumentException("Cannot set to invalid state: " + state);
- }
-
- this.scannerState = state;
- return state;
- }
-
- /**
- * @return true when a partial result is formed. A partial result is formed when a limit is
- * reached in the middle of a row.
- */
- boolean partialResultFormed() {
- return scannerState == NextState.SIZE_LIMIT_REACHED_MID_ROW;
- }
-
- /**
- * @param checkerScope
- * @return true if the batch limit can be enforced in the checker's scope
- */
- boolean hasBatchLimit(LimitScope checkerScope) {
- return limits.canEnforceBatchLimitFromScope(checkerScope) && limits.getBatch() > 0;
- }
-
- /**
- * @param checkerScope
- * @return true if the size limit can be enforced in the checker's scope
- */
- boolean hasSizeLimit(LimitScope checkerScope) {
- return limits.canEnforceSizeLimitFromScope(checkerScope) && limits.getSize() > 0;
- }
-
- /**
- * @param checkerScope
- * @return true if any limit can be enforced within the checker's scope
- */
- boolean hasAnyLimit(LimitScope checkerScope) {
- return hasBatchLimit(checkerScope) || hasSizeLimit(checkerScope);
- }
-
- /**
- * @param scope The scope in which the size limit will be enforced
- */
- void setSizeLimitScope(LimitScope scope) {
- limits.setSizeScope(scope);
- }
-
- int getBatchLimit() {
- return limits.getBatch();
- }
-
- long getSizeLimit() {
- return limits.getSize();
- }
-
- /**
- * @param checkerScope The scope that the limit is being checked from
- * @return true when the limit is enforceable from the checker's scope and it has been reached
- */
- boolean checkBatchLimit(LimitScope checkerScope) {
- return hasBatchLimit(checkerScope) && progress.getBatch() >= limits.getBatch();
- }
-
- /**
- * @param checkerScope The scope that the limit is being checked from
- * @return true when the limit is enforceable from the checker's scope and it has been reached
- */
- boolean checkSizeLimit(LimitScope checkerScope) {
- return hasSizeLimit(checkerScope) && progress.getSize() >= limits.getSize();
- }
-
- /**
- * @param checkerScope The scope that the limits are being checked from
- * @return true when some limit is enforceable from the checker's scope and it has been reached
- */
- boolean checkAnyLimitReached(LimitScope checkerScope) {
- return checkSizeLimit(checkerScope) || checkBatchLimit(checkerScope);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("{");
-
- sb.append("limits:");
- sb.append(limits);
-
- sb.append(", progress:");
- sb.append(progress);
-
- sb.append(", keepProgress:");
- sb.append(keepProgress);
-
- sb.append(", state:");
- sb.append(scannerState);
-
- sb.append("}");
- return sb.toString();
- }
-
- public static Builder newBuilder() {
- return new Builder();
- }
-
- public static Builder newBuilder(boolean keepProgress) {
- return new Builder(keepProgress);
- }
-
- public static final class Builder {
- boolean keepProgress = DEFAULT_KEEP_PROGRESS;
- LimitFields limits = new LimitFields();
-
- private Builder() {
- }
-
- private Builder(boolean keepProgress) {
- this.keepProgress = keepProgress;
- }
-
- public Builder setKeepProgress(boolean keepProgress) {
- this.keepProgress = keepProgress;
- return this;
- }
-
- public Builder setSizeLimit(LimitScope sizeScope, long sizeLimit) {
- limits.setSize(sizeLimit);
- limits.setSizeScope(sizeScope);
- return this;
- }
-
- public Builder setBatchLimit(int batchLimit) {
- limits.setBatch(batchLimit);
- return this;
- }
-
- public ScannerContext build() {
- return new ScannerContext(keepProgress, limits);
- }
- }
-
- /**
- * The possible states a scanner may be in following a call to {@link InternalScanner#next(List)}
- */
- public enum NextState {
- MORE_VALUES(true, false),
- NO_MORE_VALUES(false, false),
- SIZE_LIMIT_REACHED(true, true),
-
- /**
- * Special case of size limit reached to indicate that the size limit was reached in the middle
- * of a row and thus a partial results was formed
- */
- SIZE_LIMIT_REACHED_MID_ROW(true, true),
- BATCH_LIMIT_REACHED(true, true);
-
- private boolean moreValues;
- private boolean limitReached;
-
- private NextState(boolean moreValues, boolean limitReached) {
- this.moreValues = moreValues;
- this.limitReached = limitReached;
- }
-
- /**
- * @return true when the state indicates that more values may follow those that have been
- * returned
- */
- public boolean hasMoreValues() {
- return this.moreValues;
- }
-
- /**
- * @return true when the state indicates that a limit has been reached and scan should stop
- */
- public boolean limitReached() {
- return this.limitReached;
- }
-
- public static boolean isValidState(NextState state) {
- return state != null;
- }
-
- public static boolean hasMoreValues(NextState state) {
- return isValidState(state) && state.hasMoreValues();
- }
- }
-
- /**
- * The various scopes where a limit can be enforced. Used to differentiate when a limit should be
- * enforced or not.
- */
- public enum LimitScope {
- /**
- * Enforcing a limit between rows means that the limit will not be considered until all the
- * cells for a particular row have been retrieved
- */
- BETWEEN_ROWS(0),
-
- /**
- * Enforcing a limit between cells means that the limit will be considered after each full cell
- * has been retrieved
- */
- BETWEEN_CELLS(1);
-
- /**
- * When enforcing a limit, we must check that the scope is appropriate for enforcement.
- * <p>
- * To communicate this concept, each scope has a depth. A limit will be enforced if the depth of
- * the checker's scope is less than or equal to the limit's scope. This means that when checking
- * limits, the checker must know their own scope (i.e. are they checking the limits between
- * rows, between cells, etc...)
- */
- int depth;
-
- LimitScope(int depth) {
- this.depth = depth;
- }
-
- int depth() {
- return depth;
- }
-
- /**
- * @param checkerScope The scope in which the limit is being checked
- * @return true when the checker is in a scope that indicates the limit can be enforced. Limits
- * can be enforced from "higher or equal" scopes (i.e. the checker's scope is at a
- * lesser depth than the limit)
- */
- boolean canEnforceLimitFromScope(LimitScope checkerScope) {
- return checkerScope != null && checkerScope.depth() <= depth;
- }
- }
-
- /**
- * The different fields that can be used as limits in calls to
- * {@link InternalScanner#next(java.util.List)} and {@link RegionScanner#next(java.util.List)}
- */
- private static class LimitFields {
- /**
- * Default values of the limit fields. Defined such that if a field does NOT change from its
- * default, it will not be enforced
- */
- private static int DEFAULT_BATCH = -1;
- private static long DEFAULT_SIZE = -1L;
-
- /**
- * Default scope that is assigned to a limit if a scope is not specified.
- */
- private static final LimitScope DEFAULT_SCOPE = LimitScope.BETWEEN_ROWS;
-
- // The batch limit will always be enforced between cells, thus, there isn't a field to hold the
- // batch scope
- int batch = DEFAULT_BATCH;
-
- LimitScope sizeScope = DEFAULT_SCOPE;
- long size = DEFAULT_SIZE;
-
- /**
- * Fields keep their default values.
- */
- LimitFields() {
- }
-
- LimitFields(int batch, LimitScope sizeScope, long size) {
- setFields(batch, sizeScope, size);
- }
-
- void copy(LimitFields limitsToCopy) {
- if (limitsToCopy != null) {
- setFields(limitsToCopy.getBatch(), limitsToCopy.getSizeScope(), limitsToCopy.getSize());
- }
- }
-
- /**
- * Set all fields together.
- * @param batch
- * @param sizeScope
- * @param size
- */
- void setFields(int batch, LimitScope sizeScope, long size) {
- setBatch(batch);
- setSizeScope(sizeScope);
- setSize(size);
- }
-
- int getBatch() {
- return this.batch;
- }
-
- void setBatch(int batch) {
- this.batch = batch;
- }
-
- /**
- * @param checkerScope
- * @return true when the limit can be enforced from the scope of the checker
- */
- boolean canEnforceBatchLimitFromScope(LimitScope checkerScope) {
- return LimitScope.BETWEEN_CELLS.canEnforceLimitFromScope(checkerScope);
- }
-
- long getSize() {
- return this.size;
- }
-
- void setSize(long size) {
- this.size = size;
- }
-
- /**
- * @return {@link LimitScope} indicating scope in which the size limit is enforced
- */
- LimitScope getSizeScope() {
- return this.sizeScope;
- }
-
- /**
- * Change the scope in which the size limit is enforced
- */
- void setSizeScope(LimitScope scope) {
- this.sizeScope = scope;
- }
-
- /**
- * @param checkerScope
- * @return true when the limit can be enforced from the scope of the checker
- */
- boolean canEnforceSizeLimitFromScope(LimitScope checkerScope) {
- return this.sizeScope.canEnforceLimitFromScope(checkerScope);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("{");
-
- sb.append("batch:");
- sb.append(batch);
-
- sb.append(", size:");
- sb.append(size);
-
- sb.append(", sizeScope:");
- sb.append(sizeScope);
-
- sb.append("}");
- return sb.toString();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
index bcc0a90..831673d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
@@ -30,6 +30,7 @@ import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.monitoring.MonitoredTask;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.compactions.Compactor;
/**
@@ -109,14 +110,10 @@ abstract class StoreFlusher {
Compactor.CellSink sink, long smallestReadPoint) throws IOException {
int compactionKVMax =
conf.getInt(HConstants.COMPACTION_KV_MAX, HConstants.COMPACTION_KV_MAX_DEFAULT);
-
- ScannerContext scannerContext =
- ScannerContext.newBuilder().setBatchLimit(compactionKVMax).build();
-
List<Cell> kvs = new ArrayList<Cell>();
boolean hasMore;
do {
- hasMore = scanner.next(kvs, scannerContext);
+ hasMore = NextState.hasMoreValues(scanner.next(kvs, compactionKVMax));
if (!kvs.isEmpty()) {
for (Cell c : kvs) {
// If we know that this KV is going to be included always, then let us
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
index 2cc7c96..298d5bc 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
@@ -43,8 +43,6 @@ import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.executor.ExecutorService;
import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.hbase.regionserver.ScanQueryMatcher.MatchCode;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope;
-import org.apache.hadoop.hbase.regionserver.ScannerContext.NextState;
import org.apache.hadoop.hbase.regionserver.handler.ParallelSeekHandler;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
@@ -444,39 +442,45 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
}
}
+ /**
+ * Get the next row of values from this Store.
+ * @param outResult
+ * @param limit
+ * @return true if there are more rows, false if scanner is done
+ */
@Override
- public boolean next(List<Cell> outResult) throws IOException {
- return next(outResult, NoLimitScannerContext.NO_LIMIT);
+ public NextState next(List<Cell> outResult, int limit) throws IOException {
+ // -1 means no limit
+ return next(outResult, limit, -1);
}
/**
* Get the next row of values from this Store.
* @param outResult
- * @param scannerContext
+ * @param limit
+ * @param remainingResultSize
* @return true if there are more rows, false if scanner is done
*/
@Override
- public boolean next(List<Cell> outResult, ScannerContext scannerContext) throws IOException {
+ public NextState next(List<Cell> outResult, int limit, long remainingResultSize)
+ throws IOException {
lock.lock();
try {
- if (scannerContext == null) {
- throw new IllegalArgumentException("Scanner context cannot be null");
- }
if (checkReseek()) {
- return scannerContext.setScannerState(NextState.MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.MORE_VALUES, 0);
}
// if the heap was left null, then the scanners had previously run out anyways, close and
// return.
if (this.heap == null) {
close();
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, 0);
}
Cell peeked = this.heap.peek();
if (peeked == null) {
close();
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, 0);
}
// only call setRow if the row changes; avoids confusing the query matcher
@@ -485,18 +489,16 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
int offset = peeked.getRowOffset();
short length = peeked.getRowLength();
- // If no limits exists in the scope LimitScope.Between_Cells then we are sure we are changing
- // rows. Else it is possible we are still traversing the same row so we must perform the row
- // comparison.
- if (!scannerContext.hasAnyLimit(LimitScope.BETWEEN_CELLS) || matcher.row == null ||
- !Bytes.equals(row, offset, length, matcher.row, matcher.rowOffset, matcher.rowLength)) {
- this.countPerRow = 0;
- matcher.setRow(row, offset, length);
+ // If limit < 0 and remainingResultSize < 0 we can skip the row comparison because we know
+ // the row has changed. Else it is possible we are still traversing the same row so we
+ // must perform the row comparison.
+ if ((limit < 0 && remainingResultSize < 0) || matcher.row == null
+ || !Bytes.equals(row, offset, length, matcher.row, matcher.rowOffset,
+ matcher.rowLength)) {
+ this.countPerRow = 0;
+ matcher.setRow(row, offset, length);
}
- // Clear progress away unless invoker has indicated it should be kept.
- if (!scannerContext.getKeepProgress()) scannerContext.clearProgress();
-
Cell cell;
// Only do a sanity-check if store and comparator are available.
@@ -505,6 +507,7 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
int count = 0;
long totalBytesRead = 0;
+ long totalHeapSize = 0;
LOOP: while((cell = this.heap.peek()) != null) {
if (prevCell != cell) ++kvsScanned; // Do object compare - we set prevKV from the same heap.
@@ -529,7 +532,7 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
this.countPerRow > (storeLimit + storeOffset)) {
// do what SEEK_NEXT_ROW does.
if (!matcher.moreRowsMayExistAfter(cell)) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, totalHeapSize);
}
seekToNextRow(cell);
break LOOP;
@@ -539,15 +542,9 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
// also update metric accordingly
if (this.countPerRow > storeOffset) {
outResult.add(cell);
-
- // Update local tracking information
count++;
totalBytesRead += CellUtil.estimatedSerializedSizeOf(cell);
-
- // Update the progress of the scanner context
- scannerContext.incrementSizeProgress(CellUtil.estimatedHeapSizeOfWithoutTags(cell));
- scannerContext.incrementBatchProgress(1);
-
+ totalHeapSize += CellUtil.estimatedHeapSizeOfWithoutTags(cell);
if (totalBytesRead > maxRowSize) {
throw new RowTooBigException("Max row size allowed: " + maxRowSize
+ ", but the row is bigger than that.");
@@ -556,7 +553,7 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
if (qcode == ScanQueryMatcher.MatchCode.INCLUDE_AND_SEEK_NEXT_ROW) {
if (!matcher.moreRowsMayExistAfter(cell)) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, totalHeapSize);
}
seekToNextRow(cell);
} else if (qcode == ScanQueryMatcher.MatchCode.INCLUDE_AND_SEEK_NEXT_COL) {
@@ -565,26 +562,26 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
this.heap.next();
}
- if (scannerContext.checkBatchLimit(LimitScope.BETWEEN_CELLS)) {
+ if (limit > 0 && (count == limit)) {
break LOOP;
}
- if (scannerContext.checkSizeLimit(LimitScope.BETWEEN_CELLS)) {
+ if (remainingResultSize > 0 && (totalHeapSize >= remainingResultSize)) {
break LOOP;
}
continue;
case DONE:
- return scannerContext.setScannerState(NextState.MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.MORE_VALUES, totalHeapSize);
case DONE_SCAN:
close();
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, totalHeapSize);
case SEEK_NEXT_ROW:
// This is just a relatively simple end of scan fix, to short-cut end
// us if there is an endKey in the scan.
if (!matcher.moreRowsMayExistAfter(cell)) {
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, totalHeapSize);
}
seekToNextRow(cell);
@@ -614,12 +611,12 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
}
if (count > 0) {
- return scannerContext.setScannerState(NextState.MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.MORE_VALUES, totalHeapSize);
}
// No more keys
close();
- return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues();
+ return NextState.makeState(NextState.State.NO_MORE_VALUES, totalHeapSize);
} finally {
lock.unlock();
}
@@ -658,6 +655,11 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
return qcode;
}
+ @Override
+ public NextState next(List<Cell> outResult) throws IOException {
+ return next(outResult, -1);
+ }
+
// Implementation of ChangedReadersObserver
@Override
public void updateReaders() throws IOException {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
index d1bb657..ae820b5 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java
@@ -38,8 +38,8 @@ import org.apache.hadoop.hbase.io.hfile.HFile;
import org.apache.hadoop.hbase.io.hfile.HFile.FileInfo;
import org.apache.hadoop.hbase.regionserver.HStore;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.ScanType;
-import org.apache.hadoop.hbase.regionserver.ScannerContext;
import org.apache.hadoop.hbase.regionserver.Store;
import org.apache.hadoop.hbase.regionserver.StoreFile;
import org.apache.hadoop.hbase.regionserver.StoreFileScanner;
@@ -246,13 +246,10 @@ public abstract class Compactor {
store.getRegionInfo().getRegionNameAsString() + "#" + store.getFamily().getNameAsString();
long now = 0;
boolean hasMore;
- ScannerContext scannerContext =
- ScannerContext.newBuilder().setBatchLimit(compactionKVMax).build();
-
throughputController.start(compactionName);
try {
do {
- hasMore = scanner.next(cells, scannerContext);
+ hasMore = NextState.hasMoreValues(scanner.next(cells, compactionKVMax));
if (LOG.isDebugEnabled()) {
now = EnvironmentEdgeManager.currentTime();
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessControlLists.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessControlLists.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessControlLists.java
index fafc5a5..a01f8a1 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessControlLists.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessControlLists.java
@@ -62,6 +62,7 @@ import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos;
import org.apache.hadoop.hbase.regionserver.BloomType;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.security.User;
import org.apache.hadoop.hbase.util.Bytes;
@@ -368,7 +369,7 @@ public class AccessControlLists {
while (true) {
List<Cell> row = new ArrayList<Cell>();
- boolean hasNext = iScanner.next(row);
+ boolean hasNext = NextState.hasMoreValues(iScanner.next(row));
ListMultimap<String,TablePermission> perms = ArrayListMultimap.create();
byte[] entry = null;
for (Cell kv : row) {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java
index cd8f5ff..2bab7e8 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java
@@ -87,11 +87,11 @@ import org.apache.hadoop.hbase.protobuf.generated.QuotaProtos.Quotas;
import org.apache.hadoop.hbase.protobuf.generated.SecureBulkLoadProtos.CleanupBulkLoadRequest;
import org.apache.hadoop.hbase.protobuf.generated.SecureBulkLoadProtos.PrepareBulkLoadRequest;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.regionserver.ScanType;
-import org.apache.hadoop.hbase.regionserver.ScannerContext;
import org.apache.hadoop.hbase.regionserver.Store;
import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
import org.apache.hadoop.hbase.replication.ReplicationEndpoint;
@@ -807,12 +807,10 @@ public class AccessController extends BaseMasterAndRegionObserver
boolean foundColumn = false;
try {
boolean more = false;
- ScannerContext scannerContext = ScannerContext.newBuilder().setBatchLimit(1).build();
-
do {
cells.clear();
// scan with limit as 1 to hold down memory use on wide rows
- more = scanner.next(cells, scannerContext);
+ more = NextState.hasMoreValues(scanner.next(cells, 1));
for (Cell cell: cells) {
if (LOG.isTraceEnabled()) {
LOG.trace("Found cell " + cell);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestCase.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestCase.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestCase.java
index 0d5b27e..7d1ff0d 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestCase.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestCase.java
@@ -42,6 +42,7 @@ import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.FSTableDescriptors;
@@ -567,7 +568,7 @@ public abstract class HBaseTestCase extends TestCase {
@Override
public boolean next(List<Cell> results)
throws IOException {
- return scanner.next(results);
+ return NextState.hasMoreValues(scanner.next(results));
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/TestPartialResultsFromClientSide.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestPartialResultsFromClientSide.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestPartialResultsFromClientSide.java
index eef955e..e7c3813 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestPartialResultsFromClientSide.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestPartialResultsFromClientSide.java
@@ -409,7 +409,6 @@ public class TestPartialResultsFromClientSide {
scan.setBatch(batch);
ResultScanner scanner = TABLE.getScanner(scan);
Result result = scanner.next();
- int repCount = 0;
while ((result = scanner.next()) != null) {
assertTrue(result.rawCells() != null);
@@ -417,12 +416,11 @@ public class TestPartialResultsFromClientSide {
if (result.isPartial()) {
final String error =
"Cells:" + result.rawCells().length + " Batch size:" + batch
- + " cellsPerPartialResult:" + cellsPerPartialResult + " rep:" + repCount;
+ + " cellsPerPartialResult:" + cellsPerPartialResult;
assertTrue(error, result.rawCells().length <= Math.min(batch, cellsPerPartialResult));
} else {
assertTrue(result.rawCells().length <= batch);
}
- repCount++;
}
scanner.close();
@@ -460,7 +458,7 @@ public class TestPartialResultsFromClientSide {
do {
partialResult = partialScanner.next();
partials.add(partialResult);
- } while (partialResult != null && partialResult.isPartial());
+ } while (partialResult.isPartial());
completeResult = Result.createCompleteResult(partials);
oneShotResult = oneShotScanner.next();
@@ -698,7 +696,7 @@ public class TestPartialResultsFromClientSide {
LOG.info("r2: " + r2);
}
- final String failureMessage = "Results r1:" + r1 + " \nr2:" + r2 + " are not equivalent";
+ final String failureMessage = "Results r1:" + r1 + " r2:" + r2 + " are not equivalent";
if (r1 == null && r2 == null) fail(failureMessage);
else if (r1 == null || r2 == null) fail(failureMessage);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestIntraRowPagination.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestIntraRowPagination.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestIntraRowPagination.java
index 1f6dc98..cdfb774 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestIntraRowPagination.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestIntraRowPagination.java
@@ -28,6 +28,7 @@ import org.apache.hadoop.hbase.HTestConst;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.regionserver.HRegion;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.testclassification.ClientTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
@@ -93,7 +94,7 @@ public class TestIntraRowPagination {
RegionScanner scanner = region.getScanner(scan);
List<Cell> kvListScan = new ArrayList<Cell>();
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results) || !results.isEmpty()) {
+ while (NextState.hasMoreValues(scanner.next(results)) || !results.isEmpty()) {
kvListScan.addAll(results);
results.clear();
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java
index bfc1230..efc8db2 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java
@@ -42,7 +42,6 @@ import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.HRegionInfo;
import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.NotServingRegionException;
import org.apache.hadoop.hbase.RegionLocations;
import org.apache.hadoop.hbase.TableNotFoundException;
@@ -660,34 +659,25 @@ public class TestReplicasClient {
private void runMultipleScansOfOneType(boolean reversed, boolean small) throws Exception {
openRegion(hriSecondary);
int NUMROWS = 100;
- int NUMCOLS = 10;
try {
for (int i = 0; i < NUMROWS; i++) {
byte[] b1 = Bytes.toBytes("testUseRegionWithReplica" + i);
- for (int col = 0; col < NUMCOLS; col++) {
- Put p = new Put(b1);
- String qualifier = "qualifer" + col;
- KeyValue kv = new KeyValue(b1, f, qualifier.getBytes());
- p.add(kv);
- table.put(p);
- }
+ Put p = new Put(b1);
+ p.add(f, b1, b1);
+ table.put(p);
}
LOG.debug("PUT done");
int caching = 20;
- long maxResultSize = Long.MAX_VALUE;
-
byte[] start;
if (reversed) start = Bytes.toBytes("testUseRegionWithReplica" + (NUMROWS - 1));
else start = Bytes.toBytes("testUseRegionWithReplica" + 0);
- scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, maxResultSize,
- start, NUMROWS, NUMCOLS, false, false);
+ scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, start, NUMROWS, false, false);
- // Even if we were to slow the server down, unless we ask for stale
- // we won't get it
+ //Even if we were to slow the server down, unless we ask for stale
+ //we won't get it
SlowMeCopro.sleepTime.set(5000);
- scanWithReplicas(reversed, small, Consistency.STRONG, caching, maxResultSize, start, NUMROWS,
- NUMCOLS, false, false);
+ scanWithReplicas(reversed, small, Consistency.STRONG, caching, start, NUMROWS, false, false);
SlowMeCopro.sleepTime.set(0);
flushRegion(hriPrimary);
@@ -696,32 +686,13 @@ public class TestReplicasClient {
//Now set the flag to get a response even if stale
SlowMeCopro.sleepTime.set(5000);
- scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, maxResultSize,
- start, NUMROWS, NUMCOLS, true, false);
+ scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, start, NUMROWS, true, false);
SlowMeCopro.sleepTime.set(0);
// now make some 'next' calls slow
SlowMeCopro.slowDownNext.set(true);
SlowMeCopro.countOfNext.set(0);
- scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, maxResultSize, start,
- NUMROWS, NUMCOLS, true, true);
- SlowMeCopro.slowDownNext.set(false);
- SlowMeCopro.countOfNext.set(0);
-
- // Make sure we do not get stale data..
- SlowMeCopro.sleepTime.set(5000);
- scanWithReplicas(reversed, small, Consistency.STRONG, caching, maxResultSize,
- start, NUMROWS, NUMCOLS, false, false);
- SlowMeCopro.sleepTime.set(0);
-
- // While the next calls are slow, set maxResultSize to 1 so that some partial results will be
- // returned from the server before the replica switch occurs.
- maxResultSize = 1;
- SlowMeCopro.slowDownNext.set(true);
- SlowMeCopro.countOfNext.set(0);
- scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, maxResultSize, start,
- NUMROWS, NUMCOLS, true, true);
- maxResultSize = Long.MAX_VALUE;
+ scanWithReplicas(reversed, small, Consistency.TIMELINE, caching, start, NUMROWS, true, true);
SlowMeCopro.slowDownNext.set(false);
SlowMeCopro.countOfNext.set(0);
} finally {
@@ -739,60 +710,33 @@ public class TestReplicasClient {
}
private void scanWithReplicas(boolean reversed, boolean small, Consistency consistency,
- int caching, long maxResultSize, byte[] startRow, int numRows, int numCols,
- boolean staleExpected, boolean slowNext)
+ int caching, byte[] startRow, int numRows, boolean staleExpected, boolean slowNext)
throws Exception {
Scan scan = new Scan(startRow);
scan.setCaching(caching);
- scan.setMaxResultSize(maxResultSize);
scan.setReversed(reversed);
scan.setSmall(small);
scan.setConsistency(consistency);
ResultScanner scanner = table.getScanner(scan);
Iterator<Result> iter = scanner.iterator();
-
- // Maps of row keys that we have seen so far
HashMap<String, Boolean> map = new HashMap<String, Boolean>();
-
- // Tracked metrics
- int rowCount = 0;
- int cellCount = 0;
+ int count = 0;
int countOfStale = 0;
-
while (iter.hasNext()) {
- rowCount++;
+ count++;
Result r = iter.next();
- String row = new String(r.getRow());
-
- if (map.containsKey(row)) {
+ if (map.containsKey(new String(r.getRow()))) {
throw new Exception("Unexpected scan result. Repeated row " + Bytes.toString(r.getRow()));
}
-
- map.put(row, true);
-
- for (Cell cell : r.rawCells()) {
- cellCount++;
- }
-
+ map.put(new String(r.getRow()), true);
if (!slowNext) Assert.assertTrue(r.isStale() == staleExpected);
if (r.isStale()) countOfStale++;
}
- Assert.assertTrue("Count of rows " + rowCount + " num rows expected " + numRows,
- rowCount == numRows);
- Assert.assertTrue("Count of cells: " + cellCount + " cells expected: " + numRows * numCols,
- cellCount == (numRows * numCols));
-
+ LOG.debug("Count of rows " + count + " num rows expected " + numRows);
+ Assert.assertTrue(count == numRows);
if (slowNext) {
LOG.debug("Count of Stale " + countOfStale);
- Assert.assertTrue(countOfStale > 1);
-
- // If the scan was configured in such a way that a full row was NOT retrieved before the
- // replica switch occurred, then it is possible that all rows were stale
- if (maxResultSize != Long.MAX_VALUE) {
- Assert.assertTrue(countOfStale <= numRows);
- } else {
- Assert.assertTrue(countOfStale < numRows);
- }
+ Assert.assertTrue(countOfStale > 1 && countOfStale < numRows);
}
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpoint.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpoint.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpoint.java
index 8aa8da1..68053c0 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpoint.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpoint.java
@@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationP
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationProtos.SumResponse;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.RpcCallback;
@@ -88,7 +89,7 @@ implements Coprocessor, CoprocessorService {
boolean hasMore = false;
do {
curVals.clear();
- hasMore = scanner.next(curVals);
+ hasMore = NextState.hasMoreValues(scanner.next(curVals));
for (Cell kv : curVals) {
if (CellUtil.matchingQualifier(kv, qualifier)) {
sumResult += Bytes.toInt(kv.getValueArray(), kv.getValueOffset());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointNullResponse.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointNullResponse.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointNullResponse.java
index 4315946..c9a628a 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointNullResponse.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointNullResponse.java
@@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationW
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithNullResponseProtos.SumResponse;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.util.Bytes;
@@ -97,7 +98,7 @@ implements Coprocessor, CoprocessorService {
boolean hasMore = false;
do {
curVals.clear();
- hasMore = scanner.next(curVals);
+ hasMore = NextState.hasMoreValues(scanner.next(curVals));
for (Cell kv : curVals) {
if (CellUtil.matchingQualifier(kv, qualifier)) {
sumResult += Bytes.toInt(kv.getValueArray(), kv.getValueOffset());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointWithErrors.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointWithErrors.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointWithErrors.java
index 54289ef..0c4d076 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointWithErrors.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/ColumnAggregationEndpointWithErrors.java
@@ -35,6 +35,7 @@ import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationW
import org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationWithErrorsProtos.SumResponse;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.util.Bytes;
@@ -97,7 +98,7 @@ implements Coprocessor, CoprocessorService {
boolean hasMore = false;
do {
curVals.clear();
- hasMore = scanner.next(curVals);
+ hasMore = NextState.hasMoreValues(scanner.next(curVals));
for (Cell kv : curVals) {
if (CellUtil.matchingQualifier(kv, qualifier)) {
sumResult += Bytes.toInt(kv.getValueArray(), kv.getValueOffset());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java
index a8b5456..10ecae3 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java
@@ -58,7 +58,6 @@ import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.regionserver.ScanType;
-import org.apache.hadoop.hbase.regionserver.ScannerContext;
import org.apache.hadoop.hbase.regionserver.SplitTransaction;
import org.apache.hadoop.hbase.regionserver.SplitTransactionFactory;
import org.apache.hadoop.hbase.regionserver.Store;
@@ -88,26 +87,36 @@ public class TestCoprocessorInterface {
}
@Override
- public boolean next(List<Cell> results) throws IOException {
+ public NextState next(List<Cell> results) throws IOException {
return delegate.next(results);
}
@Override
- public boolean next(List<Cell> result, ScannerContext scannerContext)
+ public NextState next(List<Cell> result, int limit) throws IOException {
+ return delegate.next(result, limit);
+ }
+
+ @Override
+ public NextState next(List<Cell> result, int limit, long remainingResultSize)
throws IOException {
- return delegate.next(result, scannerContext);
+ return delegate.next(result, limit, remainingResultSize);
}
@Override
- public boolean nextRaw(List<Cell> result)
+ public NextState nextRaw(List<Cell> result)
throws IOException {
return delegate.nextRaw(result);
}
@Override
- public boolean nextRaw(List<Cell> result, ScannerContext context)
+ public NextState nextRaw(List<Cell> result, int limit) throws IOException {
+ return delegate.nextRaw(result, limit);
+ }
+
+ @Override
+ public NextState nextRaw(List<Cell> result, int limit, long remainingResultSize)
throws IOException {
- return delegate.nextRaw(result, context);
+ return delegate.nextRaw(result, limit, remainingResultSize);
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java
index 438cf2d..a4963ae 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java
@@ -66,10 +66,8 @@ import org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles;
import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
-import org.apache.hadoop.hbase.regionserver.NoLimitScannerContext;
import org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost;
import org.apache.hadoop.hbase.regionserver.ScanType;
-import org.apache.hadoop.hbase.regionserver.ScannerContext;
import org.apache.hadoop.hbase.regionserver.Store;
import org.apache.hadoop.hbase.regionserver.StoreFile;
import org.apache.hadoop.hbase.testclassification.CoprocessorTests;
@@ -435,17 +433,24 @@ public class TestRegionObserverInterface {
Store store, final InternalScanner scanner, final ScanType scanType) {
return new InternalScanner() {
@Override
- public boolean next(List<Cell> results) throws IOException {
- return next(results, NoLimitScannerContext.NO_LIMIT);
+ public NextState next(List<Cell> results) throws IOException {
+ return next(results, -1);
}
@Override
- public boolean next(List<Cell> results, ScannerContext scannerContext)
+ public NextState next(List<Cell> results, int limit) throws IOException {
+ return next(results, limit, -1);
+ }
+
+ @Override
+ public NextState next(List<Cell> results, int limit, long remainingResultSize)
throws IOException {
List<Cell> internalResults = new ArrayList<Cell>();
boolean hasMore;
+ NextState state;
do {
- hasMore = scanner.next(internalResults, scannerContext);
+ state = scanner.next(internalResults, limit, remainingResultSize);
+ hasMore = state != null && state.hasMoreValues();
if (!internalResults.isEmpty()) {
long row = Bytes.toLong(CellUtil.cloneValue(internalResults.get(0)));
if (row % 2 == 0) {
@@ -460,7 +465,7 @@ public class TestRegionObserverInterface {
if (!internalResults.isEmpty()) {
results.addAll(internalResults);
}
- return hasMore;
+ return state;
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestColumnPrefixFilter.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestColumnPrefixFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestColumnPrefixFilter.java
index 828842d..abd9921 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestColumnPrefixFilter.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestColumnPrefixFilter.java
@@ -40,6 +40,7 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.FilterTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -104,8 +105,7 @@ public class TestColumnPrefixFilter {
InternalScanner scanner = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results))
- ;
+ while (NextState.hasMoreValues(scanner.next(results)));
assertEquals(prefixMap.get(s).size(), results.size());
}
} finally {
@@ -170,8 +170,7 @@ public class TestColumnPrefixFilter {
InternalScanner scanner = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results))
- ;
+ while (NextState.hasMoreValues(scanner.next(results)));
assertEquals(prefixMap.get(s).size(), results.size());
}
} finally {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestDependentColumnFilter.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestDependentColumnFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestDependentColumnFilter.java
index add549a..97f0874 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestDependentColumnFilter.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestDependentColumnFilter.java
@@ -43,6 +43,7 @@ import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.filter.Filter.ReturnCode;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.FilterTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -150,7 +151,7 @@ public class TestDependentColumnFilter {
int i = 0;
int cells = 0;
for (boolean done = true; done; i++) {
- done = scanner.next(results);
+ done = NextState.hasMoreValues(scanner.next(results));
Arrays.sort(results.toArray(new KeyValue[results.size()]),
KeyValue.COMPARATOR);
LOG.info("counter=" + i + ", " + results);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java
index 5fcf64e..82ea5d4 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java
@@ -47,6 +47,7 @@ import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.filter.FilterList.Operator;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.testclassification.FilterTests;
@@ -502,7 +503,7 @@ public class TestFilter {
InternalScanner scanner = this.region.getScanner(s);
int scannerCounter = 0;
while (true) {
- boolean isMoreResults = scanner.next(new ArrayList<Cell>());
+ boolean isMoreResults = NextState.hasMoreValues(scanner.next(new ArrayList<Cell>()));
scannerCounter++;
if (scannerCounter >= pageSize) {
@@ -531,7 +532,7 @@ public class TestFilter {
InternalScanner scanner = this.region.getScanner(s);
while (true) {
ArrayList<Cell> values = new ArrayList<Cell>();
- boolean isMoreResults = scanner.next(values);
+ boolean isMoreResults = NextState.hasMoreValues(scanner.next(values));
if (!isMoreResults
|| !Bytes.toString(values.get(0).getRow()).startsWith(prefix)) {
Assert.assertTrue(
@@ -565,7 +566,7 @@ public class TestFilter {
InternalScanner scanner = this.region.getScanner(s);
int scannerCounter = 0;
while (true) {
- boolean isMoreResults = scanner.next(new ArrayList<Cell>());
+ boolean isMoreResults = NextState.hasMoreValues(scanner.next(new ArrayList<Cell>()));
scannerCounter++;
if (scannerCounter >= pageSize) {
@@ -643,7 +644,7 @@ public class TestFilter {
InternalScanner scanner = this.region.getScanner(s);
while (true) {
ArrayList<Cell> values = new ArrayList<Cell>();
- boolean isMoreResults = scanner.next(values);
+ boolean isMoreResults = NextState.hasMoreValues(scanner.next(values));
if (!isMoreResults || !Bytes.toString(CellUtil.cloneRow(values.get(0))).startsWith(prefix)) {
assertTrue("The WhileMatchFilter should now filter all remaining", filter.filterAllRemaining());
}
@@ -672,7 +673,7 @@ public class TestFilter {
InternalScanner scanner = this.region.getScanner(s);
while (true) {
ArrayList<Cell> values = new ArrayList<Cell>();
- boolean isMoreResults = scanner.next(values);
+ boolean isMoreResults = NextState.hasMoreValues(scanner.next(values));
assertTrue("The WhileMatchFilter should now filter all remaining", filter.filterAllRemaining());
if (!isMoreResults) {
break;
@@ -1475,7 +1476,7 @@ public class TestFilter {
InternalScanner scanner = testRegion.getScanner(s1);
List<Cell> results = new ArrayList<Cell>();
int resultCount = 0;
- while (scanner.next(results)) {
+ while (NextState.hasMoreValues(scanner.next(results))) {
resultCount++;
byte[] row = CellUtil.cloneRow(results.get(0));
LOG.debug("Found row: " + Bytes.toStringBinary(row));
@@ -1617,7 +1618,7 @@ public class TestFilter {
List<Cell> results = new ArrayList<Cell>();
int i = 0;
for (boolean done = true; done; i++) {
- done = scanner.next(results);
+ done = NextState.hasMoreValues(scanner.next(results));
Arrays.sort(results.toArray(new KeyValue[results.size()]),
KeyValue.COMPARATOR);
LOG.info("counter=" + i + ", " + results);
@@ -1639,7 +1640,7 @@ public class TestFilter {
List<Cell> results = new ArrayList<Cell>();
int i = 0;
for (boolean done = true; done; i++) {
- done = scanner.next(results);
+ done = NextState.hasMoreValues(scanner.next(results));
Arrays.sort(results.toArray(new KeyValue[results.size()]),
KeyValue.COMPARATOR);
LOG.info("counter=" + i + ", " + results);
@@ -1661,7 +1662,7 @@ public class TestFilter {
int row = 0;
int idx = 0;
for (boolean done = true; done; row++) {
- done = scanner.next(results);
+ done = NextState.hasMoreValues(scanner.next(results));
Arrays.sort(results.toArray(new KeyValue[results.size()]),
KeyValue.COMPARATOR);
if(results.isEmpty()) break;
@@ -1692,7 +1693,7 @@ public class TestFilter {
int row = 0;
int idx = 0;
for (boolean more = true; more; row++) {
- more = scanner.next(results);
+ more = NextState.hasMoreValues(scanner.next(results));
Arrays.sort(results.toArray(new KeyValue[results.size()]),
KeyValue.COMPARATOR);
if(results.isEmpty()) break;
@@ -2028,7 +2029,7 @@ public class TestFilter {
List<Cell> results = new ArrayList<Cell>();
int i = 5;
for (boolean done = true; done; i++) {
- done = scanner.next(results);
+ done = NextState.hasMoreValues(scanner.next(results));
assertTrue(CellUtil.matchingRow(results.get(0), Bytes.toBytes("row" + i)));
assertEquals(Bytes.toInt(CellUtil.cloneValue(results.get(0))), i%2);
results.clear();
@@ -2051,7 +2052,7 @@ public class TestFilter {
assertEquals(Bytes.toInt(CellUtil.cloneValue(results.get(0))), i%2);
results.clear();
}
- assertFalse(scanner.next(results));
+ assertFalse(NextState.hasMoreValues(scanner.next(results)));
// 3. let's begin to verify nested filter list
// 3.1 add rowFilter, then add subFilterList
FilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ONE);
@@ -2073,7 +2074,7 @@ public class TestFilter {
assertEquals(Bytes.toInt(CellUtil.cloneValue(results.get(0))), i%2);
results.clear();
}
- assertFalse(scanner.next(results));
+ assertFalse(NextState.hasMoreValues(scanner.next(results)));
// 3.2 MAGIC here! add subFilterList first, then add rowFilter
filterList = new FilterList(FilterList.Operator.MUST_PASS_ONE);
filterList.addFilter(subFilterList);
@@ -2094,7 +2095,7 @@ public class TestFilter {
assertEquals(Bytes.toInt(CellUtil.cloneValue(results.get(0))), i%2);
results.clear();
}
- assertFalse(scanner.next(results));
+ assertFalse(NextState.hasMoreValues(scanner.next(results)));
WAL wal = ((HRegion)testRegion).getWAL();
((HRegion)testRegion).close();
wal.close();
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestInvocationRecordFilter.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestInvocationRecordFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestInvocationRecordFilter.java
index a8651d8..b88bbbf 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestInvocationRecordFilter.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestInvocationRecordFilter.java
@@ -34,11 +34,12 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
+import org.apache.hadoop.hbase.wal.WAL;
import org.apache.hadoop.hbase.testclassification.FilterTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
-import org.apache.hadoop.hbase.wal.WAL;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
@@ -139,7 +140,7 @@ public class TestInvocationRecordFilter {
List<Cell> actualValues = new ArrayList<Cell>();
List<Cell> temp = new ArrayList<Cell>();
InternalScanner scanner = this.region.getScanner(scan);
- while (scanner.next(temp)) {
+ while (NextState.hasMoreValues(scanner.next(temp))) {
actualValues.addAll(temp);
temp.clear();
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestMultipleColumnPrefixFilter.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestMultipleColumnPrefixFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestMultipleColumnPrefixFilter.java
index 7b700b7..25f2e88 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestMultipleColumnPrefixFilter.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestMultipleColumnPrefixFilter.java
@@ -40,6 +40,7 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.FilterTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -109,7 +110,7 @@ public class TestMultipleColumnPrefixFilter {
scan.setFilter(filter);
List<Cell> results = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- while (scanner.next(results))
+ while (NextState.hasMoreValues(scanner.next(results)))
;
assertEquals(prefixMap.get("p").size() + prefixMap.get("q").size(), results.size());
@@ -182,7 +183,7 @@ public class TestMultipleColumnPrefixFilter {
scan.setFilter(filter);
List<Cell> results = new ArrayList<Cell>();
InternalScanner scanner = region.getScanner(scan);
- while (scanner.next(results))
+ while (NextState.hasMoreValues(scanner.next(results)))
;
assertEquals(prefixMap.get("p").size() + prefixMap.get("q").size(), results.size());
@@ -227,7 +228,7 @@ public class TestMultipleColumnPrefixFilter {
scan1.setFilter(multiplePrefixFilter);
List<Cell> results1 = new ArrayList<Cell>();
InternalScanner scanner1 = region.getScanner(scan1);
- while (scanner1.next(results1))
+ while (NextState.hasMoreValues(scanner1.next(results1)))
;
ColumnPrefixFilter singlePrefixFilter;
@@ -238,7 +239,7 @@ public class TestMultipleColumnPrefixFilter {
scan2.setFilter(singlePrefixFilter);
List<Cell> results2 = new ArrayList<Cell>();
InternalScanner scanner2 = region.getScanner(scan1);
- while (scanner2.next(results2))
+ while (NextState.hasMoreValues(scanner2.next(results2)))
;
assertEquals(results1.size(), results2.size());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestPrefixTree.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestPrefixTree.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestPrefixTree.java
index e31a73b..1eda567 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestPrefixTree.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestPrefixTree.java
@@ -37,6 +37,7 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.regionserver.RegionScanner;
import org.apache.hadoop.hbase.testclassification.IOTests;
@@ -116,7 +117,7 @@ public class TestPrefixTree {
RegionScanner scanner = region.getScanner(scan);
List<Cell> cells = new ArrayList<Cell>();
for (int i = 0; i < 3; i++) {
- assertEquals(i < 2, scanner.next(cells));
+ assertEquals(i < 2, NextState.hasMoreValues(scanner.next(cells)));
CellScanner cellScanner = Result.create(cells).cellScanner();
while (cellScanner.advance()) {
assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner
@@ -135,7 +136,7 @@ public class TestPrefixTree {
scan.setStopRow(Bytes.toBytes("a-b-A-1:"));
scanner = region.getScanner(scan);
for (int i = 1; i < 3; i++) {
- assertEquals(i < 2, scanner.next(cells));
+ assertEquals(i < 2, NextState.hasMoreValues(scanner.next(cells)));
CellScanner cellScanner = Result.create(cells).cellScanner();
while (cellScanner.advance()) {
assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner
@@ -151,7 +152,7 @@ public class TestPrefixTree {
scan.setStopRow(Bytes.toBytes("a-b-A-1:"));
scanner = region.getScanner(scan);
for (int i = 1; i < 3; i++) {
- assertEquals(i < 2, scanner.next(cells));
+ assertEquals(i < 2, NextState.hasMoreValues(scanner.next(cells)));
CellScanner cellScanner = Result.create(cells).cellScanner();
while (cellScanner.advance()) {
assertEquals(rows[i], Bytes.toString(cellScanner.current().getRowArray(), cellScanner
@@ -166,7 +167,7 @@ public class TestPrefixTree {
scan.setStartRow(Bytes.toBytes("a-b-A-1-140239"));
scan.setStopRow(Bytes.toBytes("a-b-A-1:"));
scanner = region.getScanner(scan);
- assertFalse(scanner.next(cells));
+ assertFalse(NextState.hasMoreValues(scanner.next(cells)));
assertFalse(cells.isEmpty());
scanner.close();
}
@@ -185,7 +186,7 @@ public class TestPrefixTree {
Scan scan = new Scan(Bytes.toBytes("obj29995"));
RegionScanner scanner = region.getScanner(scan);
List<Cell> cells = new ArrayList<Cell>();
- assertFalse(scanner.next(cells));
+ assertFalse(NextState.hasMoreValues(scanner.next(cells)));
assertArrayEquals(Bytes.toBytes("obj3"), Result.create(cells).getRow());
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingKeyRange.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingKeyRange.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingKeyRange.java
index 7584cf2..6baadbb 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingKeyRange.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingKeyRange.java
@@ -37,9 +37,10 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.BloomType;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
-import org.apache.hadoop.hbase.regionserver.Region;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.IOTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
+import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.util.Bytes;
import org.junit.AfterClass;
import org.junit.Test;
@@ -121,7 +122,7 @@ public class TestScannerSelectionUsingKeyRange {
cache.clearCache();
InternalScanner scanner = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results)) {
+ while (NextState.hasMoreValues(scanner.next(results))) {
}
scanner.close();
assertEquals(0, results.size());
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingTTL.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingTTL.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingTTL.java
index d5f4bcd..4e0743d 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingTTL.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestScannerSelectionUsingTTL.java
@@ -37,6 +37,7 @@ import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.regionserver.HStore;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.regionserver.Region;
import org.apache.hadoop.hbase.testclassification.IOTests;
import org.apache.hadoop.hbase.testclassification.MediumTests;
@@ -139,7 +140,7 @@ public class TestScannerSelectionUsingTTL {
final int expectedKVsPerRow = numFreshFiles * NUM_COLS_PER_ROW;
int numReturnedRows = 0;
LOG.info("Scanning the entire table");
- while (scanner.next(results) || results.size() > 0) {
+ while (NextState.hasMoreValues(scanner.next(results)) || results.size() > 0) {
assertEquals(expectedKVsPerRow, results.size());
++numReturnedRows;
results.clear();
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
index 66e1952..478e239 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestAtomicOperation.java
@@ -60,10 +60,11 @@ import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.filter.BinaryComparator;
import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import org.apache.hadoop.hbase.io.HeapSize;
+import org.apache.hadoop.hbase.wal.WAL;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.VerySlowRegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
-import org.apache.hadoop.hbase.wal.WAL;
import org.junit.After;
import org.junit.Before;
import org.junit.Rule;
@@ -466,8 +467,7 @@ public class TestAtomicOperation {
Scan s = new Scan(row);
RegionScanner rs = region.getScanner(s);
List<Cell> r = new ArrayList<Cell>();
- while (rs.next(r))
- ;
+ while(NextState.hasMoreValues(rs.next(r)));
rs.close();
if (r.size() != 1) {
LOG.debug(r);
@@ -561,8 +561,7 @@ public class TestAtomicOperation {
Scan s = new Scan();
RegionScanner scanner = region.getScanner(s);
List<Cell> results = new ArrayList<Cell>();
- ScannerContext scannerContext = ScannerContext.newBuilder().setBatchLimit(2).build();
- scanner.next(results, scannerContext);
+ scanner.next(results, 2);
for (Cell keyValue : results) {
assertEquals("50",Bytes.toString(CellUtil.cloneValue(keyValue)));
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestBlocksScanned.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestBlocksScanned.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestBlocksScanned.java
index b2ba97c..446c64c 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestBlocksScanned.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestBlocksScanned.java
@@ -25,14 +25,15 @@ import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.KeyValueUtil;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
+import org.apache.hadoop.hbase.testclassification.RegionServerTests;
+import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.io.compress.Compression;
import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
import org.apache.hadoop.hbase.io.hfile.CacheConfig;
import org.apache.hadoop.hbase.io.hfile.CacheStats;
-import org.apache.hadoop.hbase.testclassification.RegionServerTests;
-import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
import org.junit.Assert;
import org.junit.Before;
@@ -102,8 +103,7 @@ public class TestBlocksScanned extends HBaseTestCase {
InternalScanner s = r.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (s.next(results))
- ;
+ while (NextState.hasMoreValues(s.next(results)));
s.close();
int expectResultSize = 'z' - 'a';
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestColumnSeeking.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestColumnSeeking.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestColumnSeeking.java
index 1d5c61b..c09b32d 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestColumnSeeking.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestColumnSeeking.java
@@ -43,6 +43,7 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -160,7 +161,7 @@ public class TestColumnSeeking {
}
InternalScanner scanner = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results))
+ while (NextState.hasMoreValues(scanner.next(results)))
;
assertEquals(kvSet.size(), results.size());
assertTrue(KeyValueTestUtil.containsIgnoreMvccVersion(results, kvSet));
@@ -272,7 +273,7 @@ public class TestColumnSeeking {
}
InternalScanner scanner = region.getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
- while (scanner.next(results))
+ while (NextState.hasMoreValues(scanner.next(results)))
;
assertEquals(kvSet.size(), results.size());
assertTrue(KeyValueTestUtil.containsIgnoreMvccVersion(results, kvSet));
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestDefaultMemStore.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestDefaultMemStore.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestDefaultMemStore.java
index 622c145..e1e5b89 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestDefaultMemStore.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestDefaultMemStore.java
@@ -48,6 +48,7 @@ import org.apache.hadoop.hbase.KeyValueUtil;
import org.apache.hadoop.hbase.TableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -106,7 +107,7 @@ public class TestDefaultMemStore extends TestCase {
StoreScanner s = new StoreScanner(scan, scanInfo, scanType, null, memstorescanners);
int count = 0;
try {
- while (s.next(result)) {
+ while (NextState.hasMoreValues(s.next(result))) {
LOG.info(result);
count++;
// Row count is same as column count.
@@ -126,7 +127,7 @@ public class TestDefaultMemStore extends TestCase {
s = new StoreScanner(scan, scanInfo, scanType, null, memstorescanners);
count = 0;
try {
- while (s.next(result)) {
+ while (NextState.hasMoreValues(s.next(result))) {
LOG.info(result);
// Assert the stuff is coming out in right order.
assertTrue(CellUtil.matchingRow(result.get(0), Bytes.toBytes(count)));
@@ -153,7 +154,7 @@ public class TestDefaultMemStore extends TestCase {
count = 0;
int snapshotIndex = 5;
try {
- while (s.next(result)) {
+ while (NextState.hasMoreValues(s.next(result))) {
LOG.info(result);
// Assert the stuff is coming out in right order.
assertTrue(CellUtil.matchingRow(result.get(0), Bytes.toBytes(count)));
@@ -527,7 +528,7 @@ public class TestDefaultMemStore extends TestCase {
Bytes.toBytes(startRowId)), scanInfo, scanType, null,
memstore.getScanners(0));
List<Cell> results = new ArrayList<Cell>();
- for (int i = 0; scanner.next(results); i++) {
+ for (int i = 0; NextState.hasMoreValues(scanner.next(results)); i++) {
int rowId = startRowId + i;
Cell left = results.get(0);
byte[] row1 = Bytes.toBytes(rowId);
http://git-wip-us.apache.org/repos/asf/hbase/blob/8cd3001f/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java
index 110cd36..416ee28 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java
@@ -41,6 +41,7 @@ import org.apache.hadoop.hbase.client.Durability;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
+import org.apache.hadoop.hbase.regionserver.InternalScanner.NextState;
import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.util.Bytes;
@@ -96,7 +97,7 @@ public class TestGetClosestAtOrBefore extends HBaseTestCase {
InternalScanner s = mr.getScanner(new Scan());
try {
List<Cell> keys = new ArrayList<Cell>();
- while (s.next(keys)) {
+ while (NextState.hasMoreValues(s.next(keys))) {
LOG.info(keys);
keys.clear();
}
@@ -120,7 +121,7 @@ public class TestGetClosestAtOrBefore extends HBaseTestCase {
s = mr.getScanner(scan);
try {
List<Cell> keys = new ArrayList<Cell>();
- while (s.next(keys)) {
+ while (NextState.hasMoreValues(s.next(keys))) {
mr.delete(new Delete(CellUtil.cloneRow(keys.get(0))));
keys.clear();
}