@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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, next, renewLease
protected ScanMetrics scanMetrics
protected void initScanMetrics(Scan scan)
public ScanMetrics getScanMetrics()
Scan.setScanMetricsEnabled(boolean)
.getScanMetrics
in interface ResultScanner
ScanMetrics
instance or null if scan metrics not enabled.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
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.