Package org.apache.hadoop.hbase.client

Class TracedScanResultConsumer

java.lang.Object

org.apache.hadoop.hbase.client.TracedScanResultConsumer

All Implemented Interfaces:

org.apache.hadoop.hbase.client.ScanResultConsumer, org.apache.hadoop.hbase.client.ScanResultConsumerBase, SimpleScanResultConsumer

class TracedScanResultConsumer
extends Object
implements SimpleScanResultConsumer

A wrapper over SimpleScanResultConsumer that adds tracing of spans to its implementation.

Field Summary

Fields

Modifier and Type	Field	Description
private final SimpleScanResultConsumer	delegate

Constructor Summary

Constructors

Constructor	Description
TracedScanResultConsumer(SimpleScanResultConsumer delegate)

Method Summary

Modifier and Type	Method	Description
List<org.apache.hadoop.hbase.client.Result>	getAll()
org.apache.hadoop.hbase.client.metrics.ScanMetrics	getScanMetrics()
void	onComplete()
void	onError(Throwable error)
boolean	onNext(org.apache.hadoop.hbase.client.Result result)
void	onScanMetricsCreated(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics)

Methods inherited from class java.lang.Object

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

Field Details

delegate

private final SimpleScanResultConsumer delegate

Constructor Details

TracedScanResultConsumer

public TracedScanResultConsumer(SimpleScanResultConsumer delegate)

Method Details

onScanMetricsCreated

public void onScanMetricsCreated(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics)

Specified by:

onScanMetricsCreated in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

onNext

public boolean onNext(org.apache.hadoop.hbase.client.Result result)

Specified by:

onNext in interface org.apache.hadoop.hbase.client.ScanResultConsumer

onError

public void onError(Throwable error)

Specified by:

onError in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

onComplete

public void onComplete()

Specified by:

onComplete in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

getAll

public List<org.apache.hadoop.hbase.client.Result> getAll()
                                                   throws Exception

Specified by:

getAll in interface SimpleScanResultConsumer

Throws:

Exception

getScanMetrics

public org.apache.hadoop.hbase.client.metrics.ScanMetrics getScanMetrics()

Specified by:

getScanMetrics in interface SimpleScanResultConsumer