Package org.apache.hadoop.hbase.client

Class TestAsyncTableScan

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestAsyncTableScan

org.apache.hadoop.hbase.client.TestAsyncTableScan

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestAsyncTableScan
extends AbstractTestAsyncTableScan

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	logger
private Supplier<org.apache.hadoop.hbase.client.Scan>	scanCreator

Fields inherited from class org.apache.hadoop.hbase.client.AbstractTestAsyncTableScan

CONN, COUNT, CQ1, CQ2, FAMILY, methodName, OTEL_EXT, TABLE_NAME, UTIL

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableScan(String scanType, Supplier<org.apache.hadoop.hbase.client.Scan> scanCreator)

Method Summary

Modifier and Type	Method	Description
protected void	assertTraceContinuity()	Used by implementation classes to assert the correctness of spans produced under test.
protected void	assertTraceError(org.hamcrest.Matcher<io.opentelemetry.api.common.Attributes> exceptionMatcher)	Used by implementation classes to assert the correctness of spans having errors.
protected org.apache.hadoop.hbase.client.Scan	createScan()
protected List<org.apache.hadoop.hbase.client.Result>	doScan(org.apache.hadoop.hbase.client.Scan scan, int closeAfter)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestAsyncTableScan

convertFromBatchResult, getScanCreatorParams, getTableAndScanCreatorParams, setUp, setUpBeforeClass, spanStream, tearDownAfterClass, testReversedScanAll, testReversedScanAtRegionBoundary, testReversedScanWithLimit, testReversedScanWithLimitGreaterThanActualCount, testReversedScanWithStartKeyAndStopKey, testReverseScanNoStopKey, testScanAll, testScanAtRegionBoundary, testScanEndingEarly, testScanNoStopKey, testScanWithLimit, testScanWithLimitGreaterThanActualCount, testScanWithStartKeyAndStopKey, testScanWrongColumnFamily, waitForSpan

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final org.slf4j.Logger logger

scanCreator

private Supplier<org.apache.hadoop.hbase.client.Scan> scanCreator

Constructor Details

TestAsyncTableScan

public TestAsyncTableScan(String scanType,
 Supplier<org.apache.hadoop.hbase.client.Scan> scanCreator)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

createScan

protected org.apache.hadoop.hbase.client.Scan createScan()

Specified by:

createScan in class AbstractTestAsyncTableScan

doScan

protected List<org.apache.hadoop.hbase.client.Result> doScan(org.apache.hadoop.hbase.client.Scan scan,
 int closeAfter)
                                                      throws Exception

Specified by:

doScan in class AbstractTestAsyncTableScan

Throws:

Exception

assertTraceContinuity

protected void assertTraceContinuity()

Description copied from class: AbstractTestAsyncTableScan

Used by implementation classes to assert the correctness of spans produced under test.

Specified by:

assertTraceContinuity in class AbstractTestAsyncTableScan

assertTraceError

protected void assertTraceError(org.hamcrest.Matcher<io.opentelemetry.api.common.Attributes> exceptionMatcher)

Description copied from class: AbstractTestAsyncTableScan

Used by implementation classes to assert the correctness of spans having errors.

Specified by:

assertTraceError in class AbstractTestAsyncTableScan