Package 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	Description
private static final class	TestResultScannerTracing.Setup

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TestResultScannerTracing()

Method Summary

Modifier and Type	Method	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 Details

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 Details

TestResultScannerTracing

public TestResultScannerTracing()

Method Details

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