org.apache.hadoop.hbase.client
Class ScannerCallable
java.lang.Object
org.apache.hadoop.hbase.client.ServerCallable<Result[]>
org.apache.hadoop.hbase.client.ScannerCallable
- All Implemented Interfaces:
- Callable<Result[]>
public class ScannerCallable
- extends ServerCallable<Result[]>
Retries scanner operations such as create, next, etc.
Used by ResultScanner
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,
Scan scan)
- Parameters:
connection
- which connectiontableName
- table callable is onscan
- the scan to execute
instantiateServer
public void instantiateServer(boolean reload)
throws IOException
- Overrides:
instantiateServer
in class ServerCallable<Result[]>
- Parameters:
reload
- force reload of server location
- Throws:
IOException
call
public Result[] call()
throws IOException
- Throws:
IOException
- See Also:
Callable.call()
openScanner
protected long openScanner()
throws IOException
- Throws:
IOException
getScan
protected Scan getScan()
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
getCaching
public int getCaching()
- Get the number of rows that will be fetched on next
- Returns:
- the number of rows for caching
setCaching
public void setCaching(int caching)
- Set the number of rows that will be fetched on next
- Parameters:
caching
- the number of rows for caching
Copyright © 2011 The Apache Software Foundation. All Rights Reserved.