@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, next
HRegionInfo getRegionInfo()
boolean isFilterDone() throws IOException
IOException
- in case of I/O failure on a filter.boolean reseek(byte[] row) throws IOException
IOException
IllegalArgumentException
- if row is nulllong getMaxResultSize()
Scan.setMaxResultSize(long)
long getMvccReadPoint()
MultiVersionConsistencyControl
boolean 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.