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 and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
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 HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestRegionLocationCaching()

Method Summary

Modifier and Type	Method and 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.
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCachingForHTableMultiplexerMultiPut()
void	testCachingForHTableMultiplexerSinglePut()
void	testCachingForHTableMultiPut()
void	testCachingForHTableSinglePut()

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

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

Constructor Detail

TestRegionLocationCaching

public TestRegionLocationCaching()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

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