org.apache.hadoop.hbase.client

Class TestResultScannerTracing

java.lang.Object

org.apache.hadoop.hbase.client.TestResultScannerTracing

public class TestResultScannerTracing
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestResultScannerTracing.Setup

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
static org.junit.rules.TestRule	classRule
private static ConnectionRule	connectionRule
private static int	COUNT
private static byte[]	CQ
private static byte[]	FAMILY
private static org.slf4j.Logger	LOG
private static MiniClusterRule	miniClusterRule
private static OpenTelemetryClassRule	otelClassRule
OpenTelemetryTestRule	otelTestRule
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor and Description
TestResultScannerTracing()

Method Summary

Modifier and Type	Method and Description
private void	assertAsyncPrefetchScan(org.apache.hadoop.hbase.client.Scan scan)
private void	assertDefaultScan(org.apache.hadoop.hbase.client.Scan scan)
private void	assertReversedScan(org.apache.hadoop.hbase.client.Scan scan)
void	before()
private org.apache.hadoop.hbase.client.Scan	buildAsyncPrefetchScan()
private org.apache.hadoop.hbase.client.Scan	buildDefaultScan()
private org.apache.hadoop.hbase.client.Scan	buildReversedScan()
private void	doScan(Supplier<org.apache.hadoop.hbase.client.Scan> spanSupplier, Consumer<org.apache.hadoop.hbase.client.Scan> scanAssertions)
void	testAsyncPrefetchScan()
void	testNormalScan()
void	testReversedScan()
private static void	waitForSpan(org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> parentSpanMatcher)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static final byte[] FAMILY

CQ

private static final byte[] CQ

COUNT

private static final int COUNT

See Also:

Constant Field Values

otelClassRule

private static final OpenTelemetryClassRule otelClassRule

miniClusterRule

private static final MiniClusterRule miniClusterRule

connectionRule

private static final ConnectionRule connectionRule

classRule

public static final org.junit.rules.TestRule classRule

otelTestRule

public final OpenTelemetryTestRule otelTestRule

testName

public final org.junit.rules.TestName testName

Constructor Detail

TestResultScannerTracing

public TestResultScannerTracing()

Method Detail

before

public void before()
            throws Exception

Throws:

Exception

waitForSpan

private static void waitForSpan(org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> parentSpanMatcher)

buildDefaultScan

private org.apache.hadoop.hbase.client.Scan buildDefaultScan()

assertDefaultScan

private void assertDefaultScan(org.apache.hadoop.hbase.client.Scan scan)

buildAsyncPrefetchScan

private org.apache.hadoop.hbase.client.Scan buildAsyncPrefetchScan()

assertAsyncPrefetchScan

private void assertAsyncPrefetchScan(org.apache.hadoop.hbase.client.Scan scan)

buildReversedScan

private org.apache.hadoop.hbase.client.Scan buildReversedScan()

assertReversedScan

private void assertReversedScan(org.apache.hadoop.hbase.client.Scan scan)

doScan

private void doScan(Supplier<org.apache.hadoop.hbase.client.Scan> spanSupplier,
                    Consumer<org.apache.hadoop.hbase.client.Scan> scanAssertions)
             throws Exception

Throws:

Exception

testNormalScan

public void testNormalScan()
                    throws Exception

Throws:

Exception

testAsyncPrefetchScan

public void testAsyncPrefetchScan()
                           throws Exception

Throws:

Exception

testReversedScan

public void testReversedScan()
                      throws Exception

Throws:

Exception