Package org.apache.hadoop.hbase.client

Class AbstractTestAsyncTableScan

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestAsyncTableScan

Direct Known Subclasses:

TestAsyncTableScan, TestAsyncTableScanAll, TestAsyncTableScanner, TestRawAsyncTableScan

public abstract class AbstractTestAsyncTableScan
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.hbase.client.AsyncConnection	CONN
protected static int	COUNT
protected static byte[]	CQ1
protected static byte[]	CQ2
protected static byte[]	FAMILY
protected String	methodName
protected static final io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension	OTEL_EXT
protected static org.apache.hadoop.hbase.TableName	TABLE_NAME
protected static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
AbstractTestAsyncTableScan()

Method Summary

Modifier and Type	Method	Description
private void	assertResultEquals(org.apache.hadoop.hbase.client.Result result, int i)
protected abstract void	assertTraceContinuity()	Used by implementation classes to assert the correctness of spans produced under test.
protected abstract void	assertTraceError(org.hamcrest.Matcher<io.opentelemetry.api.common.Attributes> exceptionMatcher)	Used by implementation classes to assert the correctness of spans having errors.
protected final List<org.apache.hadoop.hbase.client.Result>	convertFromBatchResult(List<org.apache.hadoop.hbase.client.Result> results)
private static org.apache.hadoop.hbase.client.Scan	createBatchScan()
private static org.apache.hadoop.hbase.client.Scan	createBatchSmallResultSizeScan()
private static org.apache.hadoop.hbase.client.Scan	createNormalScan()
protected abstract org.apache.hadoop.hbase.client.Scan	createScan()
private static org.apache.hadoop.hbase.client.Scan	createSmallResultSizeScan()
protected abstract List<org.apache.hadoop.hbase.client.Result>	doScan(org.apache.hadoop.hbase.client.Scan scan, int closeAfter)
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getRawTable()
private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.Scan>>>	getScanCreator()
protected static Stream<org.junit.jupiter.params.provider.Arguments>	getScanCreatorParams()
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getTable()
protected static Stream<org.junit.jupiter.params.provider.Arguments>	getTableAndScanCreatorParams()
private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>>>	getTableCreator()
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
protected static Stream<io.opentelemetry.sdk.trace.data.SpanData>	spanStream()
static void	tearDownAfterClass()
private void	testReversedScan(int start, boolean startInclusive, int stop, boolean stopInclusive, int limit)
void	testReversedScanAll()
void	testReversedScanAtRegionBoundary()
void	testReversedScanWithLimit()
void	testReversedScanWithLimitGreaterThanActualCount()
void	testReversedScanWithStartKeyAndStopKey()
void	testReverseScanNoStopKey()
private void	testScan(int start, boolean startInclusive, int stop, boolean stopInclusive, int limit)
private void	testScan(int start, boolean startInclusive, int stop, boolean stopInclusive, int limit, int closeAfter)
void	testScanAll()
void	testScanAtRegionBoundary()
void	testScanEndingEarly()
void	testScanNoStopKey()
void	testScanWithLimit()
void	testScanWithLimitGreaterThanActualCount()
void	testScanWithStartKeyAndStopKey()
void	testScanWrongColumnFamily()
protected 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

OTEL_EXT

@RegisterExtension
protected static final io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension OTEL_EXT

UTIL

protected static final HBaseTestingUtil UTIL

CONN

protected static org.apache.hadoop.hbase.client.AsyncConnection CONN

methodName

protected String methodName

TABLE_NAME

protected static org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

protected static byte[] FAMILY

CQ1

protected static byte[] CQ1

CQ2

protected static byte[] CQ2

COUNT

protected static int COUNT

Constructor Details

AbstractTestAsyncTableScan

public AbstractTestAsyncTableScan()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)

createNormalScan

private static org.apache.hadoop.hbase.client.Scan createNormalScan()

createBatchScan

private static org.apache.hadoop.hbase.client.Scan createBatchScan()

createSmallResultSizeScan

private static org.apache.hadoop.hbase.client.Scan createSmallResultSizeScan()

createBatchSmallResultSizeScan

private static org.apache.hadoop.hbase.client.Scan createBatchSmallResultSizeScan()

getRawTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getRawTable()

getTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getTable()

getScanCreator

private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.Scan>>> getScanCreator()

getScanCreatorParams

protected static Stream<org.junit.jupiter.params.provider.Arguments> getScanCreatorParams()

getTableCreator

private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>>> getTableCreator()

getTableAndScanCreatorParams

protected static Stream<org.junit.jupiter.params.provider.Arguments> getTableAndScanCreatorParams()

createScan

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

doScan

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

Throws:

Exception

assertTraceContinuity

protected abstract void assertTraceContinuity()

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

assertTraceError

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

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

convertFromBatchResult

protected final List<org.apache.hadoop.hbase.client.Result> convertFromBatchResult(List<org.apache.hadoop.hbase.client.Result> results)

waitForSpan

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

spanStream

protected static Stream<io.opentelemetry.sdk.trace.data.SpanData> spanStream()

testScanAll

@TestTemplate
public void testScanAll()
                 throws Exception

Throws:

Exception

assertResultEquals

private void assertResultEquals(org.apache.hadoop.hbase.client.Result result,
 int i)

testReversedScanAll

@TestTemplate
public void testReversedScanAll()
                         throws Exception

Throws:

Exception

testScanNoStopKey

@TestTemplate
public void testScanNoStopKey()
                       throws Exception

Throws:

Exception

testReverseScanNoStopKey

@TestTemplate
public void testReverseScanNoStopKey()
                              throws Exception

Throws:

Exception

testScanWrongColumnFamily

@TestTemplate
public void testScanWrongColumnFamily()

testScan

private void testScan(int start,
 boolean startInclusive,
 int stop,
 boolean stopInclusive,
 int limit)
               throws Exception

Throws:

Exception

testScan

private void testScan(int start,
 boolean startInclusive,
 int stop,
 boolean stopInclusive,
 int limit,
 int closeAfter)
               throws Exception

Throws:

Exception

testReversedScan

private void testReversedScan(int start,
 boolean startInclusive,
 int stop,
 boolean stopInclusive,
 int limit)
                       throws Exception

Throws:

Exception

testScanWithStartKeyAndStopKey

@TestTemplate
public void testScanWithStartKeyAndStopKey()
                                    throws Exception

Throws:

Exception

testReversedScanWithStartKeyAndStopKey

@TestTemplate
public void testReversedScanWithStartKeyAndStopKey()
                                            throws Exception

Throws:

Exception

testScanAtRegionBoundary

@TestTemplate
public void testScanAtRegionBoundary()
                              throws Exception

Throws:

Exception

testReversedScanAtRegionBoundary

@TestTemplate
public void testReversedScanAtRegionBoundary()
                                      throws Exception

Throws:

Exception

testScanWithLimit

@TestTemplate
public void testScanWithLimit()
                       throws Exception

Throws:

Exception

testScanWithLimitGreaterThanActualCount

@TestTemplate
public void testScanWithLimitGreaterThanActualCount()
                                             throws Exception

Throws:

Exception

testReversedScanWithLimit

@TestTemplate
public void testReversedScanWithLimit()
                               throws Exception

Throws:

Exception

testReversedScanWithLimitGreaterThanActualCount

@TestTemplate
public void testReversedScanWithLimitGreaterThanActualCount()
                                                     throws Exception

Throws:

Exception

testScanEndingEarly

@TestTemplate
public void testScanEndingEarly()
                         throws Exception

Throws:

Exception