@InterfaceAudience.Private public class ScanPerNextResultScanner extends Object implements org.apache.hadoop.hbase.client.ResultScanner, org.apache.hadoop.hbase.client.AdvancedScanResultConsumer
Modifier and Type | Field and Description |
---|---|
private boolean |
closed |
private Throwable |
error |
private Queue<org.apache.hadoop.hbase.client.Result> |
queue |
private org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanResumer |
resumer |
private org.apache.hadoop.hbase.client.Scan |
scan |
private org.apache.hadoop.hbase.client.metrics.ScanMetrics |
scanMetrics |
private org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> |
table |
Constructor and Description |
---|
ScanPerNextResultScanner(org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> table,
org.apache.hadoop.hbase.client.Scan scan) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.hbase.client.metrics.ScanMetrics |
getScanMetrics() |
org.apache.hadoop.hbase.client.Result |
next() |
void |
onComplete() |
void |
onError(Throwable error) |
void |
onHeartbeat(org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController controller) |
void |
onNext(org.apache.hadoop.hbase.client.Result[] results,
org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController controller) |
void |
onScanMetricsCreated(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics) |
boolean |
renewLease() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
private final org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> table
private final org.apache.hadoop.hbase.client.Scan scan
private org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics
private boolean closed
private org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanResumer resumer
public ScanPerNextResultScanner(org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer> table, org.apache.hadoop.hbase.client.Scan scan)
public void onError(Throwable error)
onError
in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase
public void onComplete()
onComplete
in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase
public void onScanMetricsCreated(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics)
onScanMetricsCreated
in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase
public void onNext(org.apache.hadoop.hbase.client.Result[] results, org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController controller)
onNext
in interface org.apache.hadoop.hbase.client.AdvancedScanResultConsumer
public void onHeartbeat(org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController controller)
onHeartbeat
in interface org.apache.hadoop.hbase.client.AdvancedScanResultConsumer
public org.apache.hadoop.hbase.client.Result next() throws IOException
next
in interface org.apache.hadoop.hbase.client.ResultScanner
IOException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.hbase.client.ResultScanner
public boolean renewLease()
renewLease
in interface org.apache.hadoop.hbase.client.ResultScanner
public org.apache.hadoop.hbase.client.metrics.ScanMetrics getScanMetrics()
getScanMetrics
in interface org.apache.hadoop.hbase.client.ResultScanner
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.