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
private static byte[]	QUALIFIER
private static int	SLAVES
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	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	checkRegionLocationIsNotCached(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.Connection conn)	Method to check whether the cached region location is empty for the given table.
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCachingForHTableMultiPut()
void	testCachingForHTableSinglePut()
void	testDisableInvalidateMetaCache()
void	testInvalidateMetaCache()

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

SLAVES

private static int SLAVES

TABLE_NAME

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

FAMILY

private static byte[] FAMILY

QUALIFIER

private static byte[] QUALIFIER

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

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

checkRegionLocationIsNotCached

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

Method to check whether the cached region location is 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

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

testInvalidateMetaCache

public void testInvalidateMetaCache()
                             throws Throwable

Throws:

Throwable

testDisableInvalidateMetaCache

public void testDisableInvalidateMetaCache()
                                    throws Throwable

Throws:

Throwable