@InterfaceAudience.Private public abstract class AbstractClientScanner extends Object implements ResultScanner
Modifier and Type | Field and Description |
---|---|
protected ScanMetrics |
scanMetrics |
Constructor and Description |
---|
AbstractClientScanner() |
Modifier and Type | Method and Description |
---|---|
ScanMetrics |
getScanMetrics()
Used internally accumulating metrics on scan.
|
protected void |
initScanMetrics(Scan scan)
Check and initialize if application wants to collect scan metrics
|
Iterator<Result> |
iterator() |
Result[] |
next(int nbRows)
Get nbRows rows.
|
abstract boolean |
renewLease()
Allow the client to renew the scanner's lease on the server.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, next
protected ScanMetrics scanMetrics
protected void initScanMetrics(Scan scan)
public ScanMetrics getScanMetrics()
Scan.setScanMetricsEnabled(boolean)
.
These metrics are cleared at key transition points. Metrics are accumulated in the
Scan
object itself.ScanMetrics
instance or null if scan metrics not enabled.Scan.getScanMetrics()
public Result[] next(int nbRows) throws IOException
Scan.setCaching(int)
setting (or hbase.client.scanner.caching in hbase-site.xml).next
in interface ResultScanner
nbRows
- number of rows to returnIOException
public abstract boolean renewLease()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.