Package org.apache.hadoop.hbase.client

Class TestRegionLocationCaching

java.lang.Object

org.apache.hadoop.hbase.client.TestRegionLocationCaching

public class TestRegionLocationCaching
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
final org.junit.rules.TestName	name
private static int	PER_REGIONSERVER_QUEUE_SIZE
private static byte[]	QUALIFIER
private static int	SLAVES
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestRegionLocationCaching()

Method Summary

Modifier and Type	Method	Description
private static void	checkExistence(org.apache.hadoop.hbase.TableName tableName, byte[] row, byte[] family, byte[] qualifier)	Method to check whether the passed row exists in the given table
private void	checkRegionLocationIsCached(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.Connection conn)	Method to check whether the cached region location is non-empty for the given table.
private void	checkRegions(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ConnectionImplementation conn, List<org.apache.hadoop.hbase.client.RegionInfo> regions, org.apache.hadoop.hbase.client.RegionInfo chosen)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCachingForHTableMultiplexerMultiPut()
void	testCachingForHTableMultiplexerSinglePut()
void	testCachingForHTableMultiPut()
void	testCachingForHTableSinglePut()
void	testDoNotCacheLocationWithNullServerNameWhenGetAllLocations()

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 HBaseTestingUtility TEST_UTIL

SLAVES

private static int SLAVES

PER_REGIONSERVER_QUEUE_SIZE

private static int PER_REGIONSERVER_QUEUE_SIZE

TABLE_NAME

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

FAMILY

private static byte[] FAMILY

QUALIFIER

private static byte[] QUALIFIER

name

public final org.junit.rules.TestName name

Constructor Details

TestRegionLocationCaching

public TestRegionLocationCaching()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testDoNotCacheLocationWithNullServerNameWhenGetAllLocations

public void testDoNotCacheLocationWithNullServerNameWhenGetAllLocations()
                                                                 throws Exception

Throws:

Exception

checkRegions

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

testCachingForHTableMultiplexerSinglePut

public void testCachingForHTableMultiplexerSinglePut()
                                              throws Exception

Throws:

Exception

testCachingForHTableMultiplexerMultiPut

public void testCachingForHTableMultiplexerMultiPut()
                                             throws Exception

Throws:

Exception

testCachingForHTableSinglePut

public void testCachingForHTableSinglePut()
                                   throws Exception

Throws:

Exception

testCachingForHTableMultiPut

public void testCachingForHTableMultiPut()
                                  throws Exception

Throws:

Exception

checkRegionLocationIsCached

private void checkRegionLocationIsCached(org.apache.hadoop.hbase.TableName tableName,
 org.apache.hadoop.hbase.client.Connection conn)
                                  throws InterruptedException,
IOException

Method to check whether the cached region location is non-empty for the given table. It repeats the same check several times as clearing of cache by some async operations may not reflect immediately.

Throws:

InterruptedException

IOException

checkExistence

private static void checkExistence(org.apache.hadoop.hbase.TableName tableName,
 byte[] row,
 byte[] family,
 byte[] qualifier)
                            throws Exception

Method to check whether the passed row exists in the given table

Throws:

Exception