@InterfaceAudience.Public public interface ScanResultConsumer extends ScanResultConsumerBase
Result
for an asynchronous scan.
All results that match the given scan object will be passed to this class by calling
onNext(Result)
. ScanResultConsumerBase.onComplete()
means the scan is finished, and
ScanResultConsumerBase.onError(Throwable)
means we hit an unrecoverable error and the scan is terminated.
Modifier and Type | Method and Description |
---|---|
boolean |
onNext(Result result) |
onComplete, onError, onScanMetricsCreated
boolean onNext(Result result)
result
- the data fetched from HBase service.false
if you want to terminate the scan process. Otherwise true
Copyright © 2007–2019 Cloudera. All rights reserved.