Package org.apache.hadoop.hbase.client

Class TestAsyncNonMetaRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncNonMetaRegionLocator

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestAsyncNonMetaRegionLocator
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.client.AsyncConnectionImpl	conn
private static byte[]	FAMILY
private org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator	locator
private final org.apache.hadoop.hbase.CatalogReplicaMode	metaReplicaMode
private static final int	NB_SERVERS
private static final int	NUM_OF_META_REPLICA
private static byte[][]	SPLIT_KEYS
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestAsyncNonMetaRegionLocator(org.apache.hadoop.hbase.CatalogReplicaMode metaReplicaMode)

Method Summary

Modifier and Type	Method	Description
private void	assertLocEquals(byte[] startKey, byte[] endKey, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.HRegionLocation loc)
private void	checkRegions(org.apache.hadoop.hbase.client.AsyncConnectionImpl conn, List<org.apache.hadoop.hbase.client.RegionInfo> regions, org.apache.hadoop.hbase.client.RegionInfo chosen)
private void	checkRegionsWithRetries(org.apache.hadoop.hbase.client.AsyncConnectionImpl conn, List<org.apache.hadoop.hbase.client.RegionInfo> regions, org.apache.hadoop.hbase.client.RegionInfo chosen, int retries)
private void	createMultiRegionTable()
private void	createSingleRegionTable()
private CompletableFuture<org.apache.hadoop.hbase.HRegionLocation>	getDefaultRegionLocation(org.apache.hadoop.hbase.TableName tableName, byte[] row, org.apache.hadoop.hbase.client.RegionLocateType locateType, boolean reload)
private static byte[][]	getEndKeys()
private org.apache.hadoop.hbase.ServerName[]	getLocations(byte[][] startKeys)
private static byte[][]	getStartKeys()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
static void	setUp()
void	setUpBeforeTest()
static void	tearDown()
void	tearDownAfterTest()
void	testCacheLocationWhenGetAllLocations()
void	testConcurrentLocate()
void	testConcurrentUpdateCachedLocationOnError()
void	testDisableTable()
void	testDoNotCacheLocationWithNullServerNameWhenGetAllLocations()
void	testLocateAfter()
void	testLocateBeforeInOnlyRegion()
void	testLocateBeforeLastRegion()
void	testMultiRegionTable()
void	testNoTable()
void	testRegionMove()
void	testRegionReplicas()
void	testReload()
void	testSingleRegionTable()

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static byte[] FAMILY

NB_SERVERS

private static final int NB_SERVERS

See Also:

• Constant Field Values

NUM_OF_META_REPLICA

private static final int NUM_OF_META_REPLICA

See Also:

• Constant Field Values

SPLIT_KEYS

private static byte[][] SPLIT_KEYS

conn

private org.apache.hadoop.hbase.client.AsyncConnectionImpl conn

locator

private org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator locator

metaReplicaMode

private final org.apache.hadoop.hbase.CatalogReplicaMode metaReplicaMode

Constructor Details

TestAsyncNonMetaRegionLocator

public TestAsyncNonMetaRegionLocator(org.apache.hadoop.hbase.CatalogReplicaMode metaReplicaMode)

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

setUpBeforeTest

@BeforeEach
public void setUpBeforeTest()
                     throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

tearDownAfterTest

@AfterEach
public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

parameters

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

createSingleRegionTable

private void createSingleRegionTable()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getDefaultRegionLocation

private CompletableFuture<org.apache.hadoop.hbase.HRegionLocation> getDefaultRegionLocation(org.apache.hadoop.hbase.TableName tableName,
 byte[] row,
 org.apache.hadoop.hbase.client.RegionLocateType locateType,
 boolean reload)

testNoTable

@TestTemplate
public void testNoTable()
                 throws InterruptedException

Throws:

InterruptedException

testDisableTable

@TestTemplate
public void testDisableTable()
                      throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

assertLocEquals

private void assertLocEquals(byte[] startKey,
 byte[] endKey,
 org.apache.hadoop.hbase.ServerName serverName,
 org.apache.hadoop.hbase.HRegionLocation loc)

testSingleRegionTable

@TestTemplate
public void testSingleRegionTable()
                           throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

createMultiRegionTable

private void createMultiRegionTable()
                             throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getStartKeys

private static byte[][] getStartKeys()

getEndKeys

private static byte[][] getEndKeys()

getLocations

private org.apache.hadoop.hbase.ServerName[] getLocations(byte[][] startKeys)

testMultiRegionTable

@TestTemplate
public void testMultiRegionTable()
                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testRegionMove

@TestTemplate
public void testRegionMove()
                    throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testLocateAfter

@TestTemplate
public void testLocateAfter()
                     throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testConcurrentLocate

@TestTemplate
public void testConcurrentLocate()
                          throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testReload

@TestTemplate
public void testReload()
                throws Exception

Throws:

Exception

testLocateBeforeLastRegion

@TestTemplate
public void testLocateBeforeLastRegion()
                                throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testRegionReplicas

@TestTemplate
public void testRegionReplicas()
                        throws Exception

Throws:

Exception

testLocateBeforeInOnlyRegion

@TestTemplate
public void testLocateBeforeInOnlyRegion()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testConcurrentUpdateCachedLocationOnError

@TestTemplate
public void testConcurrentUpdateCachedLocationOnError()
                                               throws Exception

Throws:

Exception

testCacheLocationWhenGetAllLocations

@TestTemplate
public void testCacheLocationWhenGetAllLocations()
                                          throws Exception

Throws:

Exception

testDoNotCacheLocationWithNullServerNameWhenGetAllLocations

@TestTemplate
public void testDoNotCacheLocationWithNullServerNameWhenGetAllLocations()
                                                                 throws Exception

Throws:

Exception

checkRegionsWithRetries

private void checkRegionsWithRetries(org.apache.hadoop.hbase.client.AsyncConnectionImpl conn,
 List<org.apache.hadoop.hbase.client.RegionInfo> regions,
 org.apache.hadoop.hbase.client.RegionInfo chosen,
 int retries)
                              throws InterruptedException

Throws:

InterruptedException

checkRegions

private void checkRegions(org.apache.hadoop.hbase.client.AsyncConnectionImpl conn,
 List<org.apache.hadoop.hbase.client.RegionInfo> regions,
 org.apache.hadoop.hbase.client.RegionInfo chosen)