org.apache.hadoop.hbase

Class AsyncMetaTableAccessor.MetaTableScanResultConsumer

java.lang.Object

org.apache.hadoop.hbase.AsyncMetaTableAccessor.MetaTableScanResultConsumer

All Implemented Interfaces:

AdvancedScanResultConsumer, ScanResultConsumerBase

Enclosing class:

AsyncMetaTableAccessor

private static final class AsyncMetaTableAccessor.MetaTableScanResultConsumer
extends Object
implements AdvancedScanResultConsumer

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.AdvancedScanResultConsumer

AdvancedScanResultConsumer.ScanController, AdvancedScanResultConsumer.ScanResumer

Field Summary

Fields

Modifier and Type	Field and Description
private int	currentRowCount
private CompletableFuture<Void>	future
private int	rowUpperLimit
private MetaTableAccessor.Visitor	visitor

Constructor Summary

Constructors

Constructor and Description
MetaTableScanResultConsumer(int rowUpperLimit, MetaTableAccessor.Visitor visitor, CompletableFuture<Void> future)

Method Summary

Modifier and Type	Method and Description
void	onComplete() Indicate that the scan operation is completed normally.
void	onError(Throwable error) Indicate that we hit an unrecoverable error and the scan operation is terminated.
void	onNext(Result[] results, AdvancedScanResultConsumer.ScanController controller) Indicate that we have receive some data.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.AdvancedScanResultConsumer

onHeartbeat

Methods inherited from interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

onScanMetricsCreated

Field Detail

currentRowCount

private int currentRowCount

rowUpperLimit

private final int rowUpperLimit

visitor

private final MetaTableAccessor.Visitor visitor

future

private final CompletableFuture<Void> future

Constructor Detail

MetaTableScanResultConsumer

MetaTableScanResultConsumer(int rowUpperLimit,
                            MetaTableAccessor.Visitor visitor,
                            CompletableFuture<Void> future)

Method Detail

onError

public void onError(Throwable error)

Description copied from interface: ScanResultConsumerBase

Indicate that we hit an unrecoverable error and the scan operation is terminated.

We will not call ScanResultConsumerBase.onComplete() after calling ScanResultConsumerBase.onError(Throwable).

Specified by:

onError in interface ScanResultConsumerBase

onComplete

public void onComplete()

Description copied from interface: ScanResultConsumerBase

Indicate that the scan operation is completed normally.

Specified by:

onComplete in interface ScanResultConsumerBase

onNext

public void onNext(Result[] results,
                   AdvancedScanResultConsumer.ScanController controller)

Description copied from interface: AdvancedScanResultConsumer

Indicate that we have receive some data.

Specified by:

onNext in interface AdvancedScanResultConsumer

Parameters:

results - the data fetched from HBase service.

controller - used to suspend or terminate the scan. Notice that the controller instance is only valid within scope of onNext method. You can only call its method in onNext, do NOT store it and call it later outside onNext.