Package org.apache.hadoop.hbase.client

Class TestScannersFromClientSide

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideTestBase

org.apache.hadoop.hbase.client.TestScannersFromClientSide

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

A client-side test, mostly testing scanners with various parameters. Parameterized on different registry implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestScannersFromClientSide.LimitKVsReturnFilter

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

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

FAMILY, INVALID_FAMILY, numHedgedReqs, QUALIFIER, registryImpl, ROW, SLAVES, tableName, TEST_UTIL, VALUE

Constructor Summary

Constructors

Constructor	Description
TestScannersFromClientSide(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs)

Method Summary

Modifier and Type	Method	Description
static void	setUpBeforeClass()
void	testGetMaxResults()	Test from client side for get with maxResultPerCF set
void	testGetRowOffset()	Test from client side for get with rowOffset
void	testMaxResultSizeIsSetToDefault()
void	testRawScanExpiredCell()
void	testReadExpiredDataForRawScan()
void	testReverseScanWithFlush()
void	testScanBatch()	Test from client side for batch of scan
void	testScanMaxResults()	Test from client side for scan with maxResultPerCF set
void	testScannerForNotExistingTable()	Scan on not existing table should throw the exception with correct message
void	testScannerWithPartialResults()
void	testScanOnReopenedRegion()	Test from client side for scan while the region is reopened on the same region server.
void	testScanRawDeleteFamilyVersion()
void	testScanWithColumnsAndFilterAndVersion()
void	testScanWithSameStartRowStopRow()
void	testSmallScan()
private void	testSmallScan(org.apache.hadoop.hbase.client.Table table, boolean reversed, int rows, int columns)	Run through a variety of test configurations with a small scan
private void	verifyExpectedCounts(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Scan scan, int expectedRowCount, int expectedCellCount)
(package private) static void	verifyResult(org.apache.hadoop.hbase.client.Result result, List<org.apache.hadoop.hbase.Cell> expKvList, boolean toLog, String msg)

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

assertDoubleResult, assertEmptyResult, assertIncrementKey, assertKey, assertNResult, assertNResult, assertNullResult, assertNumKeys, assertRowCount, assertSingleResult, assertSingleResult, assertSingleResult, buildScanner, createScanWithRowFilter, createScanWithRowFilter, deleteColumns, equals, getAllVersionsAndVerify, getClientConf, getConnection, getNumberOfRows, getSingleScanResult, getTestNull, getTestNull, getVerifySingleColumn, getVerifySingleEmpty, getVersionAndVerify, getVersionAndVerifyMissing, getVersionRangeAndVerify, getVersionRangeAndVerifyGreaterThan, initialize, makeN, makeNAscii, makeNBig, makeStamps, parameters, putRows, scanAllVersionsAndVerify, scanTestNull, scanTestNull, scanVerifySingleColumn, scanVerifySingleEmpty, scanVersionAndVerify, scanVersionAndVerifyMissing, scanVersionRangeAndVerify, scanVersionRangeAndVerifyGreaterThan, setUp, singleRowGetTest, singleRowScanTest, splitTable, tearDown, tearDownAfterClass

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

Constructor Details

TestScannersFromClientSide

public TestScannersFromClientSide(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl,
 int numHedgedReqs)

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testScanBatch

@TestTemplate
public void testScanBatch()
                   throws Exception

Test from client side for batch of scan

Throws:

Exception

testMaxResultSizeIsSetToDefault

@TestTemplate
public void testMaxResultSizeIsSetToDefault()
                                     throws Exception

Throws:

Exception

testScannerForNotExistingTable

@TestTemplate
public void testScannerForNotExistingTable()
                                    throws Exception

Scan on not existing table should throw the exception with correct message

Throws:

Exception

testSmallScan

@TestTemplate
public void testSmallScan()
                   throws Exception

Throws:

Exception

testSmallScan

private void testSmallScan(org.apache.hadoop.hbase.client.Table table,
 boolean reversed,
 int rows,
 int columns)
                    throws Exception

Run through a variety of test configurations with a small scan

Throws:

Exception

verifyExpectedCounts

private void verifyExpectedCounts(org.apache.hadoop.hbase.client.Table table,
 org.apache.hadoop.hbase.client.Scan scan,
 int expectedRowCount,
 int expectedCellCount)
                           throws Exception

Throws:

Exception

testGetMaxResults

@TestTemplate
public void testGetMaxResults()
                       throws Exception

Test from client side for get with maxResultPerCF set

Throws:

Exception

testScanMaxResults

@TestTemplate
public void testScanMaxResults()
                        throws Exception

Test from client side for scan with maxResultPerCF set

Throws:

Exception

testGetRowOffset

@TestTemplate
public void testGetRowOffset()
                      throws Exception

Test from client side for get with rowOffset

Throws:

Exception

testRawScanExpiredCell

@TestTemplate
public void testRawScanExpiredCell()
                            throws Exception

Throws:

Exception

testScanRawDeleteFamilyVersion

@TestTemplate
public void testScanRawDeleteFamilyVersion()
                                    throws Exception

Throws:

Exception

testScanOnReopenedRegion

@TestTemplate
public void testScanOnReopenedRegion()
                              throws Exception

Test from client side for scan while the region is reopened on the same region server.

Throws:

Exception

verifyResult

static void verifyResult(org.apache.hadoop.hbase.client.Result result,
 List<org.apache.hadoop.hbase.Cell> expKvList,
 boolean toLog,
 String msg)

testReadExpiredDataForRawScan

@TestTemplate
public void testReadExpiredDataForRawScan()
                                   throws IOException

Throws:

IOException

testScanWithColumnsAndFilterAndVersion

@TestTemplate
public void testScanWithColumnsAndFilterAndVersion()
                                            throws IOException

Throws:

IOException

testScanWithSameStartRowStopRow

@TestTemplate
public void testScanWithSameStartRowStopRow()
                                     throws IOException

Throws:

IOException

testReverseScanWithFlush

@TestTemplate
public void testReverseScanWithFlush()
                              throws Exception

Throws:

Exception

testScannerWithPartialResults

@TestTemplate
public void testScannerWithPartialResults()
                                   throws Exception

Throws:

Exception