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 and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.AsyncConnectionImpl	CONN
private static byte[]	FAMILY
private static org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator	LOCATOR
private static org.slf4j.Logger	LOG
private static int	META_STOREFILE_REFRESH_PERIOD
private org.apache.hadoop.hbase.client.CatalogReplicaMode	metaReplicaMode
private static int	NB_SERVERS
private static int	numOfMetaReplica
private static org.apache.hadoop.hbase.client.ConnectionRegistry	registry
private static byte[][]	SPLIT_KEYS
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestAsyncNonMetaRegionLocator(String clientMetaReplicaMode)

Method Summary

Modifier and Type	Method and Description
private void	assertLocEquals(byte[] startKey, byte[] endKey, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.HRegionLocation loc)
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[]>	parameters()
static void	setUp()
static void	tearDown()
void	tearDownAfterTest()
void	testConcurrentLocate()
void	testConcurrentUpdateCachedLocationOnError()
void	testDisableTable()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

TABLE_NAME

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

FAMILY

private static byte[] FAMILY

META_STOREFILE_REFRESH_PERIOD

private static final int META_STOREFILE_REFRESH_PERIOD

See Also:

Constant Field Values

NB_SERVERS

private static final int NB_SERVERS

See Also:

Constant Field Values

numOfMetaReplica

private static int numOfMetaReplica

CONN

private static org.apache.hadoop.hbase.client.AsyncConnectionImpl CONN

LOCATOR

private static org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator LOCATOR

registry

private static org.apache.hadoop.hbase.client.ConnectionRegistry registry

SPLIT_KEYS

private static byte[][] SPLIT_KEYS

metaReplicaMode

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

Constructor Detail

TestAsyncNonMetaRegionLocator

public TestAsyncNonMetaRegionLocator(String clientMetaReplicaMode)
                              throws Exception

Throws:

Exception

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

tearDownAfterTest

public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

parameters

public static Collection<Object[]> 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

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