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 byte[][]	SPLIT_KEYS
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestAsyncNonMetaRegionLocator()

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 void	setUp()
static void	tearDown()
void	tearDownAfterTest()
void	testConcurrentLocate()
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

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

TABLE_NAME

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

FAMILY

private static byte[] FAMILY

CONN

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

LOCATOR

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

SPLIT_KEYS

private static byte[][] SPLIT_KEYS

Constructor Detail

TestAsyncNonMetaRegionLocator

public TestAsyncNonMetaRegionLocator()

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

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