org.apache.hadoop.hbase.client

Class TracedAdvancedScanResultConsumer

java.lang.Object

org.apache.hadoop.hbase.client.TracedAdvancedScanResultConsumer

All Implemented Interfaces:

org.apache.hadoop.hbase.client.AdvancedScanResultConsumer, org.apache.hadoop.hbase.client.ScanResultConsumerBase

public class TracedAdvancedScanResultConsumer
extends Object
implements org.apache.hadoop.hbase.client.AdvancedScanResultConsumer

A drop-in replacement for BufferingScanResultConsumer that adds tracing spans to its implementation of the AdvancedScanResultConsumer API.

Nested Class Summary

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

org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController, org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanResumer

Field Summary

Fields

Modifier and Type	Field and Description
private BufferingScanResultConsumer	delegate

Constructor Summary

Constructors

Constructor and Description
TracedAdvancedScanResultConsumer()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.metrics.ScanMetrics	getScanMetrics()
void	onComplete()
void	onError(Throwable error)
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)
org.apache.hadoop.hbase.client.Result	take()

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

Field Detail

delegate

private final BufferingScanResultConsumer delegate

Constructor Detail

TracedAdvancedScanResultConsumer

public TracedAdvancedScanResultConsumer()

Method Detail

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 void onNext(org.apache.hadoop.hbase.client.Result[] results,
                   org.apache.hadoop.hbase.client.AdvancedScanResultConsumer.ScanController controller)

Specified by:

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

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

take

public org.apache.hadoop.hbase.client.Result take()
                                           throws IOException,
                                                  InterruptedException

Throws:

IOException

InterruptedException

getScanMetrics

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