@InterfaceAudience.Private public interface RegionScanner extends InternalScanner
| Modifier and Type | Method and Description |
|---|---|
long |
getMaxResultSize() |
long |
getMvccReadPoint() |
HRegionInfo |
getRegionInfo() |
boolean |
isFilterDone() |
boolean |
nextRaw(List<Cell> result)
Grab the next row's worth of values with the default limit on the number of values
to return.
|
boolean |
nextRaw(List<Cell> result,
int limit)
Grab the next row's worth of values with a limit on the number of values
to return.
|
boolean |
reseek(byte[] row)
Do a reseek to the required row.
|
close, next, nextHRegionInfo getRegionInfo()
boolean isFilterDone()
throws IOException
IOException - in case of I/O failure on a filter.boolean reseek(byte[] row)
throws IOException
IOExceptionIllegalArgumentException - if row is nulllong getMaxResultSize()
Scan.setMaxResultSize(long)long getMvccReadPoint()
MultiVersionConsistencyControlboolean nextRaw(List<Cell> result) throws IOException
nextRaw(List, int)result - return output arrayIOException - eboolean nextRaw(List<Cell> result, int limit) throws IOException
HRegion region = ...;
RegionScanner scanner = ...
MultiVersionConsistencyControl.setThreadReadPoint(scanner.getMvccReadPoint());
region.startRegionOperation();
try {
synchronized(scanner) {
...
boolean moreRows = scanner.nextRaw(values);
...
}
} finally {
region.closeRegionOperation();
}
result - return output arraylimit - limit on row count to getIOException - eCopyright © 2014 The Apache Software Foundation. All rights reserved.