Package org.apache.hadoop.hbase.client
Class AbstractTestAsyncTableScan
java.lang.Object
org.apache.hadoop.hbase.client.AbstractTestAsyncTableScan
- Direct Known Subclasses:
TestAsyncTableScan
,TestAsyncTableScanAll
,TestAsyncTableScanner
,TestRawAsyncTableScan
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionstatic final org.junit.rules.TestRule
protected static final ConnectionRule
protected static int
protected static byte[]
protected static byte[]
protected static byte[]
protected static final MiniClusterRule
protected static final OpenTelemetryClassRule
final OpenTelemetryTestRule
protected static org.apache.hadoop.hbase.TableName
final org.junit.rules.TestName
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate void
assertResultEquals
(org.apache.hadoop.hbase.client.Result result, int i) protected abstract void
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
private static org.apache.hadoop.hbase.client.Scan
private static org.apache.hadoop.hbase.client.Scan
protected abstract org.apache.hadoop.hbase.client.Scan
private static org.apache.hadoop.hbase.client.Scan
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<?>
private static List<org.apache.hadoop.hbase.util.Pair<String,
Supplier<org.apache.hadoop.hbase.client.Scan>>> private static org.apache.hadoop.hbase.client.AsyncTable<?>
getTable()
private static List<org.apache.hadoop.hbase.util.Pair<String,
Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>>> protected static Stream<io.opentelemetry.sdk.trace.data.SpanData>
private void
testReversedScan
(int start, boolean startInclusive, int stop, boolean stopInclusive, int limit) void
void
void
void
void
void
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
void
void
void
void
void
void
void
protected static void
waitForSpan
(org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> parentSpanMatcher)
-
Field Details
-
OTEL_CLASS_RULE
-
MINI_CLUSTER_RULE
-
CONN_RULE
-
classRule
-
otelTestRule
-
testName
-
TABLE_NAME
-
FAMILY
-
CQ1
-
CQ2
-
COUNT
-
-
Constructor Details
-
AbstractTestAsyncTableScan
public AbstractTestAsyncTableScan()
-
-
Method Details
-
createNormalScan
-
createBatchScan
-
createSmallResultSizeScan
-
createBatchSmallResultSizeScan
-
getRawTable
-
getTable
-
getScanCreator
private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.Scan>>> getScanCreator() -
getScanCreatorParams
-
getTableCreator
private static List<org.apache.hadoop.hbase.util.Pair<String,Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>>> getTableCreator() -
getTableAndScanCreatorParams
-
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
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
-
testScanAll
- Throws:
Exception
-
assertResultEquals
-
testReversedScanAll
- Throws:
Exception
-
testScanNoStopKey
- Throws:
Exception
-
testReverseScanNoStopKey
- Throws:
Exception
-
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
- Throws:
Exception
-
testReversedScanWithStartKeyAndStopKey
- Throws:
Exception
-
testScanAtRegionBoundary
- Throws:
Exception
-
testReversedScanAtRegionBoundary
- Throws:
Exception
-
testScanWithLimit
- Throws:
Exception
-
testScanWithLimitGreaterThanActualCount
- Throws:
Exception
-
testReversedScanWithLimit
- Throws:
Exception
-
testReversedScanWithLimitGreaterThanActualCount
- Throws:
Exception
-
testScanEndingEarly
- Throws:
Exception
-