Package org.apache.hadoop.hbase.client

Class TestAsyncNonMetaRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncNonMetaRegionLocator

public class TestAsyncNonMetaRegionLocator
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.client.AsyncConnectionImpl	conn
private static byte[]	FAMILY
private org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator	locator
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()

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 Collection<Object[]>	paramAbstractTestRegionLocatoreters()
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

public org.apache.hadoop.hbase.CatalogReplicaMode metaReplicaMode

Constructor Details

TestAsyncNonMetaRegionLocator

public TestAsyncNonMetaRegionLocator()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

setUpBeforeTest

public void setUpBeforeTest()
                     throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

tearDownAfterTest

public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

paramAbstractTestRegionLocatoreters

public static Collection<Object[]> paramAbstractTestRegionLocatoreters()

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

public void testNoTable()
                 throws InterruptedException

Throws:

InterruptedException

testDisableTable

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

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

public void testMultiRegionTable()
                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testRegionMove

public void testRegionMove()
                    throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testLocateAfter

public void testLocateAfter()
                     throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testConcurrentLocate

public void testConcurrentLocate()
                          throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testReload

public void testReload()
                throws Exception

Throws:

Exception

testLocateBeforeLastRegion

public void testLocateBeforeLastRegion()
                                throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testRegionReplicas

public void testRegionReplicas()
                        throws Exception

Throws:

Exception

testLocateBeforeInOnlyRegion

public void testLocateBeforeInOnlyRegion()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testConcurrentUpdateCachedLocationOnError

public void testConcurrentUpdateCachedLocationOnError()
                                               throws Exception

Throws:

Exception

testCacheLocationWhenGetAllLocations

public void testCacheLocationWhenGetAllLocations()
                                          throws Exception

Throws:

Exception

testDoNotCacheLocationWithNullServerNameWhenGetAllLocations

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)