Package 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
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hadoop.hbase.client.metrics.ScanMetrics
void
void
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 Details
-
delegate
-
-
Constructor Details
-
TracedAdvancedScanResultConsumer
public TracedAdvancedScanResultConsumer()
-
-
Method Details
-
onScanMetricsCreated
- Specified by:
onScanMetricsCreated
in interfaceorg.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 interfaceorg.apache.hadoop.hbase.client.AdvancedScanResultConsumer
-
onError
- Specified by:
onError
in interfaceorg.apache.hadoop.hbase.client.ScanResultConsumerBase
-
onComplete
- Specified by:
onComplete
in interfaceorg.apache.hadoop.hbase.client.ScanResultConsumerBase
-
take
- Throws:
IOException
InterruptedException
-
getScanMetrics
-