org.apache.hadoop.hbase.client
Class ScannerCallable
java.lang.Object
org.apache.hadoop.hbase.client.ServerCallable<RowResult>
org.apache.hadoop.hbase.client.ScannerCallable
- All Implemented Interfaces:
- Callable<RowResult>
public class ScannerCallable
- extends ServerCallable<RowResult>
Retries scanner operations such as create, next, etc.
Used by Scanner
s made by HTable
.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ScannerCallable
public ScannerCallable(HConnection connection,
byte[] tableName,
byte[][] columns,
byte[] startRow,
long timestamp,
RowFilterInterface filter)
- Parameters:
connection
- tableName
- columns
- startRow
- timestamp
- filter
-
instantiateServer
public void instantiateServer(boolean reload)
throws IOException
- Overrides:
instantiateServer
in class ServerCallable<RowResult>
- Parameters:
reload
-
- Throws:
IOException
call
public RowResult call()
throws IOException
- Throws:
IOException
openScanner
protected long openScanner()
throws IOException
- Throws:
IOException
getColumns
protected byte[][] getColumns()
getTimestamp
protected long getTimestamp()
getFilter
protected RowFilterInterface getFilter()
setClose
public void setClose()
- Call this when the next invocation of call should close the scanner
getHRegionInfo
public HRegionInfo getHRegionInfo()
- Returns:
- the HRegionInfo for the current region
Copyright © 2008 The Apache Software Foundation